Versions in this module Expand all Collapse all v0 v0.2.0 Jan 22, 2020 v0.1.0 Jan 22, 2020 Changes in this version + type ConsumeOpt struct + Args map[string]interface{} + AutoAck bool + Consumer string + Exclusive bool + NoLocal bool + NoWait bool + type ExchangeOpt struct + Args map[string]interface{} + Autodelete bool + Durable bool + Internal bool + Kind string + NoWait bool + type QueueOpt struct + Args map[string]interface{} + AutoDelete bool + Durable bool + Exclusive bool + NoWait bool + type Receiver struct + func NewReceiver(cnn, queue string) *Receiver + type Sender struct + Cnn string + Exchange string + ExchangeDeclare bool + ExchangeOpt ExchangeOpt + func NewSender(cnn, exchange string) *Sender + func (s *Sender) Connect() error + func (s *Sender) NotifyError(c chan error) chan error + func (s *Sender) Send(body []byte, routingKey string) error + type Subscriber struct + AmqpConfig *amqp.Config + Connection string + ConsumeOpt ConsumeOpt + Exchange string + PassiveMode bool + PrefetchCount int + Queue string + QueueOpt QueueOpt + func NewSubscriber(cnn, queue string) *Subscriber + func (s *Subscriber) AddQueueArg(key string, value interface{}) *Subscriber + func (s *Subscriber) Process(h func([]byte) error) error + func (s *Subscriber) SetAmqpConfig(config amqp.Config) *Subscriber + func (s *Subscriber) SetExchange(ex string) *Subscriber + func (s *Subscriber) SetPassiveMode(mode bool) *Subscriber + func (s *Subscriber) SetPrefetchCount(n int) *Subscriber
Go to main page