Versions in this module Expand all Collapse all v1 v1.0.3 Oct 26, 2023 Changes in this version + type RabbitMQ struct + Channel *amqp.Channel + Connection *amqp.Connection + func New(user, password, host, port string, reconnectTime time.Duration) (*RabbitMQ, error) + func (r *RabbitMQ) Consume(consumer string, autoAck, exclusive, noLocal, noWait bool, ...) (<-chan amqp.Delivery, error) + func (r *RabbitMQ) ExchangeDeclare(name, exchangeType string, durable, autoDelete, internal, noWait bool, ...) error + func (r *RabbitMQ) Qos(prefetchCount, prefetchSize int, global bool) error + func (r *RabbitMQ) QueueBind(key, exchangeName string, noWait bool, arguments amqp.Table) error + func (r *RabbitMQ) QueueDeclare(name string, durable, autoDelete, exclusive, noWait bool, arguments amqp.Table) error
Go to main page