errors

Jan 24, 2026

Changes in this version

+ var ErrClientClosed = errors.New("rabbitmq: client is closed")

+ var ErrMaxRetriesExceeded = errors.New("rabbitmq: max retries exceeded")

+ var ErrNoChannel = errors.New("rabbitmq: no active channel")

+ var ErrNoConnection = errors.New("rabbitmq: no active connection")

+ var ErrNoHandlersRegistered = errors.New("rabbitmq: no handlers registered, call RegisterHandler before StartConsume")

+ var ErrPublishConfirmTimeout = errors.New("rabbitmq: timeout waiting for publish confirmation")

+ var ErrPublishNotConfirmed = errors.New("rabbitmq: message publish was not confirmed by broker")

+ func NewConfigFieldError(field, message string) error

+ func NewConnectionError(operation string, cause error) error

+ func NewConsumeError(queue string, cause error) error

+ func NewHandlerError(eventType, messageID string, cause error) error

+ func NewPublishError(exchange, routingKey string, cause error) error

+ func NewTopologyError(operation, resource string, cause error) error

+ type ConfigError struct

+ Field string

+ Message string

+ func (e *ConfigError) Error() string

+ type ConnectionError struct

+ Cause error

+ Operation string

+ func (e *ConnectionError) Error() string

+ func (e *ConnectionError) Unwrap() error

+ type ConsumeError struct

+ Cause error

+ Queue string

+ func (e *ConsumeError) Error() string

+ func (e *ConsumeError) Unwrap() error

+ type HandlerError struct

+ Cause error

+ EventType string

+ MessageID string

+ func (e *HandlerError) Error() string

+ func (e *HandlerError) Unwrap() error

+ type PublishError struct

+ Cause error

+ Exchange string

+ RoutingKey string

+ func (e *PublishError) Error() string

+ func (e *PublishError) Unwrap() error

+ type TopologyError struct

+ Cause error

+ Operation string

+ Resource string

+ func (e *TopologyError) Error() string

+ func (e *TopologyError) Unwrap() error