Versions in this module Expand all Collapse all v0 v0.2.0 Oct 2, 2022 Changes in this version + type Acknowledge int + const Ack + const NackDiscard + const NackRequeue + const None + type ChannelManager interface + type Logger interface + Debug func(string, ...interface{}) + Error func(string, ...interface{}) + Fatal func(string, ...interface{}) + Info func(string, ...interface{}) + Trace func(string, ...interface{}) + Warn func(string, ...interface{}) + type Message struct + Body interface{} + type Messaging interface + AddWorker func(queue string, handler WorkerHandler) error + AddWorkerWithOptions func(queue string, handler WorkerHandler, options *WorkerOptions) error + CancelWorkers func() error + Publish func(queue string, data interface{}) error + PublishWithOptions func(queue string, data interface{}, options *PublishOptions) error + RegisterType func(value interface{}) + RpcCall func(queue string, data interface{}) (error, interface{}) + SendPush func(queue string, data interface{}) error + SendPushWithOptions func(queue string, data interface{}, options *PushOptions) error + Subscribe func(queue string, handler SubscribeHandler) error + SubscribeWithOptions func(queue string, handler SubscribeHandler, options *SubscribeOptions) error + func NewMessaging(url string) (Messaging, error) + func NewMessagingWithOptions(url string, options *MessagingOptions) (Messaging, error) + type MessagingOptions struct + Logger Logger + ReconnectInterval time.Duration + type PublishOptions struct + Durable bool + type PushOptions struct + Persistent bool + type SubscribeHandler func(message Message) + type SubscribeOptions struct + Concurrency int + Durable bool + type Subscriber struct + type Worker struct + type WorkerHandler func(message Message) (interface{}, Acknowledge) + type WorkerOptions struct + AutoAck bool + Concurrency int + Durable bool + QOSGlobal bool + QOSPrefetch int v0.1.1 Oct 1, 2022