amqp091

Jun 16, 2026

Changes in this version

+ const DefaultMaxRetryCount

+ const DefaultRetryInterval

+ var DefaultReconnectionConfig = &ReconnectionConfig

+ var ErrRecoveryNotEnabled = &Error

type Channel

+ func (ch *Channel) NotifyRecoveryCancel(receiver chan struct{}) chan struct{}

+ func (ch *Channel) NotifyStateChange(c chan *StateChanged)

+ func (ch *Channel) Reconnect() error

type Config

+ Recovery *Recovery

type Connection

+ func (c *Connection) AddRecoverableErrorCodes(codes ...int) error

+ func (c *Connection) GetRecoverableErrorCodes() []int

+ func (c *Connection) IsRecoveryEnabled() bool

+ func (c *Connection) MaxRetryCount() int

+ func (c *Connection) NotifyRecoveryCancel(receiver chan struct{}) chan struct{}

+ func (c *Connection) NotifyStateChange(ch chan *StateChanged)

+ func (c *Connection) Reconnect() error

+ func (c *Connection) RetryInterval() time.Duration

+ func (c *Connection) SetRecoverableErrorCodes(codes []int) error

+ type ConnectionRecovery interface

+ OnChannelClose func(ch *Channel, err *Error)

+ OnConnectionClose func(conn *Connection, err *Error)

+ type DefaultConnectionRecovery struct

+ func (d *DefaultConnectionRecovery) OnChannelClose(ch *Channel, err *Error)

+ func (d *DefaultConnectionRecovery) OnConnectionClose(conn *Connection, err *Error)

+ type LifeCycleState byte

+ const StateClosed

+ const StateClosing

+ const StateOpen

+ const StateReconnecting

+ func (s LifeCycleState) String() string

+ type ReconnectionConfig struct

+ MaxRetryCount int

+ RecoverableErrorCodes []int

+ RetryInterval time.Duration

+ func (rc *ReconnectionConfig) Clone() *ReconnectionConfig

+ type Recovery struct

+ ConnectionRecovery ConnectionRecovery

+ ReconnectionConfig *ReconnectionConfig

+ type StateChanged struct

+ Err error

+ From LifeCycleState

+ To LifeCycleState

+ func (s StateChanged) String() string

Apr 21, 2026

Changes in this version

+ const MimeApplicationAvro

+ const MimeApplicationCloudEventsJSON

+ const MimeApplicationFormURLEncoded

+ const MimeApplicationJSON

+ const MimeApplicationMsgPack

+ const MimeApplicationOctetStream

+ const MimeApplicationProtobuf

+ const MimeApplicationXML

+ const MimeApplicationXProtobuf

+ const MimeTextPlain

+ const MimeTextXML

+ var ErrDeliveryNotInitialized = errors.New("delivery not initialized. Channel is probably closed")

type Error

+ func (e *Error) GoString() string

+ func (e *Error) Recoverable() bool

+ func (e *Error) Temporary() bool

May 8, 2024

Changes in this version

+ const ImmediatelyExpire

+ const NeverExpire

type URI

+ AuthMechanism []string

+ ChannelMax uint16

+ ConnectionTimeout int

+ Heartbeat heartbeatDuration

Oct 2, 2023

Changes in this version

+ const ConsumerTimeoutArg

+ const QueueVersionArg

+ const SingleActiveConsumerArg

type Channel

+ func (ch *Channel) ConsumeWithContext(ctx context.Context, queue, consumer string, ...) (<-chan Delivery, error)

Mar 21, 2023

Changes in this version

type Connection

+ func (c *Connection) CloseDeadline(deadline time.Time) error

Jan 20, 2023

Changes in this version

+ const DefaultExchange

+ const QueueMaxLenArg

+ const QueueMaxLenBytesArg

+ const QueueMessageTTLArg

+ const QueueOverflowArg

+ const QueueOverflowDropHead

+ const QueueOverflowRejectPublish

+ const QueueOverflowRejectPublishDLX

+ const QueueTTLArg

+ const QueueTypeArg

+ const QueueTypeClassic

+ const QueueTypeQuorum

+ const QueueTypeStream

+ const StreamMaxAgeArg

+ const StreamMaxLenBytesArg

+ const StreamMaxSegmentSizeBytesArg

type DeferredConfirmation

+ func (d *DeferredConfirmation) Acked() bool

+ func (d *DeferredConfirmation) Done() <-chan struct{}

+ func (d *DeferredConfirmation) WaitContext(ctx context.Context) (bool, error)

Sep 7, 2022

Changes in this version

type Connection

+ func (c *Connection) UpdateSecret(newSecret, reason string) error

type Table

+ func NewConnectionProperties() Table

+ func (t Table) SetClientConnectionName(connName string)

Jul 19, 2022

Changes in this version

+ func SetLogger(logger Logging)

type Channel

+ func (ch *Channel) PublishWithContext(ctx context.Context, exchange, key string, mandatory, immediate bool, ...) error

+ func (ch *Channel) PublishWithDeferredConfirmWithContext(ctx context.Context, exchange, key string, mandatory, immediate bool, ...) (*DeferredConfirmation, error)

type Connection

+ func (c *Connection) RemoteAddr() net.Addr

type DeferredConfirmation

+ func (d *DeferredConfirmation) Confirm(ack bool)

+ type Logging interface

+ Printf func(format string, v ...interface{})

+ var Logger Logging = NullLogger{}

+ type NullLogger struct

+ func (l NullLogger) Printf(format string, v ...interface{})

type URI

+ CACertFile string

+ CertFile string

+ KeyFile string

+ ServerName string

Jan 13, 2022

Changes in this version

type Channel

+ func (ch *Channel) PublishWithDeferredConfirm(exchange, key string, mandatory, immediate bool, msg Publishing) (*DeferredConfirmation, error)

+ type DeferredConfirmation struct

+ DeliveryTag uint64

+ func (d *DeferredConfirmation) Wait() bool

Nov 17, 2021

Changes in this version

type Channel

+ func (ch *Channel) GetNextPublishSeqNo() uint64

type Connection

+ func DialTLS_ExternalAuth(url string, amqps *tls.Config) (*Connection, error)

+ type ExternalAuth struct

+ func (*ExternalAuth) Mechanism() string

+ func (*ExternalAuth) Response() string

Sep 21, 2021

Changes in this version

+ const AccessRefused

+ const ChannelError

+ const CommandInvalid

+ const ConnectionForced

+ const ContentTooLarge

+ const ExchangeDirect

+ const ExchangeFanout

+ const ExchangeHeaders

+ const ExchangeTopic

+ const FrameError

+ const InternalError

+ const InvalidPath

+ const NoConsumers

+ const NoRoute

+ const NotAllowed

+ const NotFound

+ const NotImplemented

+ const Persistent

+ const PreconditionFailed

+ const ResourceError

+ const ResourceLocked

+ const SyntaxError

+ const Transient

+ const UnexpectedFrame

+ var ErrChannelMax = &Error

+ var ErrClosed = &Error

+ var ErrCommandInvalid = &Error

+ var ErrCredentials = &Error

+ var ErrFieldType = &Error

+ var ErrFrame = &Error

+ var ErrSASL = &Error

+ var ErrSyntax = &Error

+ var ErrUnexpectedFrame = &Error

+ var ErrVhost = &Error

+ func DefaultDial(connectionTimeout time.Duration) func(network, addr string) (net.Conn, error)

+ type AMQPlainAuth struct

+ Password string

+ Username string

+ func (auth *AMQPlainAuth) Mechanism() string

+ func (auth *AMQPlainAuth) Response() string

+ type Acknowledger interface

+ Ack func(tag uint64, multiple bool) error

+ Nack func(tag uint64, multiple bool, requeue bool) error

+ Reject func(tag uint64, requeue bool) error

+ type Authentication interface

+ Mechanism func() string

+ Response func() string

+ type Blocking struct

+ Active bool

+ Reason string

+ type Channel struct

+ func (ch *Channel) Ack(tag uint64, multiple bool) error

+ func (ch *Channel) Cancel(consumer string, noWait bool) error

+ func (ch *Channel) Close() error

+ func (ch *Channel) Confirm(noWait bool) error

+ func (ch *Channel) Consume(queue, consumer string, autoAck, exclusive, noLocal, noWait bool, args Table) (<-chan Delivery, error)

+ func (ch *Channel) ExchangeBind(destination, key, source string, noWait bool, args Table) error

+ func (ch *Channel) ExchangeDeclare(name, kind string, durable, autoDelete, internal, noWait bool, args Table) error

+ func (ch *Channel) ExchangeDeclarePassive(name, kind string, durable, autoDelete, internal, noWait bool, args Table) error

+ func (ch *Channel) ExchangeDelete(name string, ifUnused, noWait bool) error

+ func (ch *Channel) ExchangeUnbind(destination, key, source string, noWait bool, args Table) error

+ func (ch *Channel) Flow(active bool) error

+ func (ch *Channel) Get(queue string, autoAck bool) (msg Delivery, ok bool, err error)

+ func (ch *Channel) IsClosed() bool

+ func (ch *Channel) Nack(tag uint64, multiple bool, requeue bool) error

+ func (ch *Channel) NotifyCancel(c chan string) chan string

+ func (ch *Channel) NotifyClose(c chan *Error) chan *Error

+ func (ch *Channel) NotifyConfirm(ack, nack chan uint64) (chan uint64, chan uint64)

+ func (ch *Channel) NotifyFlow(c chan bool) chan bool

+ func (ch *Channel) NotifyPublish(confirm chan Confirmation) chan Confirmation

+ func (ch *Channel) NotifyReturn(c chan Return) chan Return

+ func (ch *Channel) Publish(exchange, key string, mandatory, immediate bool, msg Publishing) error

+ func (ch *Channel) Qos(prefetchCount, prefetchSize int, global bool) error

+ func (ch *Channel) QueueBind(name, key, exchange string, noWait bool, args Table) error

+ func (ch *Channel) QueueDeclare(name string, durable, autoDelete, exclusive, noWait bool, args Table) (Queue, error)

+ func (ch *Channel) QueueDeclarePassive(name string, durable, autoDelete, exclusive, noWait bool, args Table) (Queue, error)

+ func (ch *Channel) QueueDelete(name string, ifUnused, ifEmpty, noWait bool) (int, error)

+ func (ch *Channel) QueueInspect(name string) (Queue, error)

+ func (ch *Channel) QueuePurge(name string, noWait bool) (int, error)

+ func (ch *Channel) QueueUnbind(name, key, exchange string, args Table) error

+ func (ch *Channel) Recover(requeue bool) error

+ func (ch *Channel) Reject(tag uint64, requeue bool) error

+ func (ch *Channel) Tx() error

+ func (ch *Channel) TxCommit() error

+ func (ch *Channel) TxRollback() error

+ type Config struct

+ ChannelMax int

+ Dial func(network, addr string) (net.Conn, error)

+ FrameSize int

+ Heartbeat time.Duration

+ Locale string

+ Properties Table

+ SASL []Authentication

+ TLSClientConfig *tls.Config

+ Vhost string

+ type Confirmation struct

+ Ack bool

+ DeliveryTag uint64

+ type Connection struct

+ Config Config

+ Locales []string

+ Major int

+ Minor int

+ Properties Table

+ func Dial(url string) (*Connection, error)

+ func DialConfig(url string, config Config) (*Connection, error)

+ func DialTLS(url string, amqps *tls.Config) (*Connection, error)

+ func Open(conn io.ReadWriteCloser, config Config) (*Connection, error)

+ func (c *Connection) Channel() (*Channel, error)

+ func (c *Connection) Close() error

+ func (c *Connection) ConnectionState() tls.ConnectionState

+ func (c *Connection) IsClosed() bool

+ func (c *Connection) LocalAddr() net.Addr

+ func (c *Connection) NotifyBlocked(receiver chan Blocking) chan Blocking

+ func (c *Connection) NotifyClose(receiver chan *Error) chan *Error

+ type Decimal struct

+ Scale uint8

+ Value int32

+ type Delivery struct

+ Acknowledger Acknowledger

+ AppId string

+ Body []byte

+ ConsumerTag string

+ ContentEncoding string

+ ContentType string

+ CorrelationId string

+ DeliveryMode uint8

+ DeliveryTag uint64

+ Exchange string

+ Expiration string

+ Headers Table

+ MessageCount uint32

+ MessageId string

+ Priority uint8

+ Redelivered bool

+ ReplyTo string

+ RoutingKey string

+ Timestamp time.Time

+ Type string

+ UserId string

+ func (d Delivery) Ack(multiple bool) error

+ func (d Delivery) Nack(multiple, requeue bool) error

+ func (d Delivery) Reject(requeue bool) error

+ type Error struct

+ Code int

+ Reason string

+ Recover bool

+ Server bool

+ func (e Error) Error() string

+ type PlainAuth struct

+ Password string

+ Username string

+ func (auth *PlainAuth) Mechanism() string

+ func (auth *PlainAuth) Response() string

+ type Publishing struct

+ AppId string

+ Body []byte

+ ContentEncoding string

+ ContentType string

+ CorrelationId string

+ DeliveryMode uint8

+ Expiration string

+ Headers Table

+ MessageId string

+ Priority uint8

+ ReplyTo string

+ Timestamp time.Time

+ Type string

+ UserId string

+ type Queue struct

+ Consumers int

+ Messages int

+ Name string

+ type Return struct

+ AppId string

+ Body []byte

+ ContentEncoding string

+ ContentType string

+ CorrelationId string

+ DeliveryMode uint8

+ Exchange string

+ Expiration string

+ Headers Table

+ MessageId string

+ Priority uint8

+ ReplyCode uint16

+ ReplyText string

+ ReplyTo string

+ RoutingKey string

+ Timestamp time.Time

+ Type string

+ UserId string

+ type Table map[string]interface

+ func (t Table) Validate() error

+ type URI struct

+ Host string

+ Password string

+ Port int

+ Scheme string

+ Username string

+ Vhost string

+ func ParseURI(uri string) (URI, error)

+ func (uri URI) AMQPlainAuth() *AMQPlainAuth

+ func (uri URI) PlainAuth() *PlainAuth

+ func (uri URI) String() string