Versions in this module Expand all Collapse all v0 v0.2.0 Dec 16, 2025 v0.1.0 Apr 18, 2025 Changes in this version + type Channel interface + Ack func(tag uint64, multiple bool) error + Cancel func(consumer string, noWait bool) error + Close func() error + Confirm func(noWait bool) error + Consume func(queue, consumer string, opt Option) (<-chan Delivery, error) + ExchangeDeclare func(name, kind string, opt Option) error + ExchangeDeclarePassive func(name, kind string, opt Option) error + Nack func(tag uint64, multiple bool, requeue bool) error + NotifyClose func(chan Error) chan Error + NotifyPublish func(confirm chan Confirmation) chan Confirmation + Qos func(prefetchCount, prefetchSize int, global bool) error + QueueBind func(name, key, exchange string, opt Option) error + QueueDeclare func(name string, args Option) (Queue, error) + QueueDeclarePassive func(name string, args Option) (Queue, error) + QueueDelete func(name string, args Option) (int, error) + QueueInspect func(name string) (Queue, error) + QueueUnbind func(name, route, exchange string, args Option) error + Reject func(tag uint64, requeue bool) error + type Confirmation interface + Ack func() bool + DeliveryTag func() uint64 + type Conn interface + AutoRedial func(errChan chan Error, done chan bool) + Channel func() (Channel, error) + Close func() error + NotifyClose func(chan Error) chan Error + type Delivery interface + Ack func(multiple bool) error + Body func() []byte + ConsumerTag func() string + ContentType func() string + DeliveryTag func() uint64 + Headers func() Option + MessageId func() string + Nack func(multiple, requeue bool) error + Reject func(requeue bool) error + RoutingKey func() string + Timestamp func() time.Time + type Error interface + Code func() int + Reason func() string + Recover func() bool + Server func() bool + type Option map[string]interface + type Publisher interface + Publish func(exc, route string, msg []byte, opt Option) error + type Queue interface + Consumers func() int + Messages func() int + Name func() string
Go to main page