Versions in this module Expand all Collapse all v0 v0.0.3 May 12, 2022 Changes in this version + type Config struct + ConsumerTag string + Dsn string + Exchange string + ExchangeType string + type Consumer struct + func NewConsumer(config *Config) *Consumer + func (c *Consumer) AnnounceQueue(queueName, bindingKey string) (<-chan amqp.Delivery, error) + func (c *Consumer) Connect() error + func (c *Consumer) Handle(d <-chan amqp.Delivery, fn func(<-chan amqp.Delivery), threads int, ...) + func (c *Consumer) ReConnect(queueName, bindingKey string) (<-chan amqp.Delivery, error)
Go to main page