rabbitmq

Jul 6, 2022

Changes in this version

+ type Consumer struct

+ func NewConsumer(amqpURI string) (*Consumer, error)

+ func (p *Consumer) Close() error

+ func (p *Consumer) Consumer(ctx context.Context, exchange, exchangeType, queueName, key, tag string, ...)

+ type Payload struct

+ Exchange string

+ ExchangeType string

+ Handle func(string, uint64, []byte) error

+ Key string

+ QueueName string

+ Tag string

+ type Producer struct

+ func NewProducer(amqpURI string) (*Producer, error)

+ func (p *Producer) Close() error

+ func (p *Producer) Producer(exchange, exchangeType, queueName, routingKey, body string, reliable bool) error