Versions in this module Expand all Collapse all v1 v1.2.5 Dec 8, 2023 v1.2.3 Dec 8, 2023 v1.2.2 Dec 8, 2023 v1.2.1 Dec 8, 2023 Changes in this version + func MustNewListener(listenerConf RabbitListenerConf, handler ConsumeHandler) queue.MessageQueue + type Admin struct + func MustNewAdmin(rabbitMqConf RabbitConf) *Admin + func (q *Admin) Bind(queueName string, routekey string, exchange string, notWait bool, ...) error + func (q *Admin) DeclareExchange(conf ExchangeConf, args amqp.Table) error + func (q *Admin) DeclareQueue(conf QueueConf, args amqp.Table) error + type ConsumeHandle func(message string) error + type ConsumeHandler interface + Consume func(message string) error + type ConsumerConf struct + AutoAck bool + Exclusive bool + Name string + NoLocal bool + NoWait bool + type ExchangeConf struct + AutoDelete bool + Durable bool + ExchangeName string + Internal bool + NoWait bool + Queues []QueueConf + Type string + type QueueConf struct + AutoDelete bool + Durable bool + Exclusive bool + Name string + NoWait bool + type RabbitConf struct + Host string + Password string + Port int + Username string + VHost string + type RabbitListener struct + func (q RabbitListener) Start() + func (q RabbitListener) Stop() + type RabbitListenerConf struct + ListenerQueues []ConsumerConf + type RabbitMqSender struct + ContentType string + func (q *RabbitMqSender) Send(exchange string, routeKey string, msg []byte) error + type RabbitSenderConf struct + ContentType string + type Sender interface + Send func(exchange string, routeKey string, msg []byte) error + func MustNewSender(rabbitMqConf RabbitSenderConf) Sender
Go to main page