errors

var (
	// ErrClientClosed is returned when attempting to use a closed client.
	ErrClientClosed = errors.New("rabbitmq: client is closed")

	// ErrNoConnection is returned when the client has no active connection.
	ErrNoConnection = errors.New("rabbitmq: no active connection")

	// ErrNoChannel is returned when the client has no active channel.
	ErrNoChannel = errors.New("rabbitmq: no active channel")

	// ErrMaxRetriesExceeded is returned when a message exceeds max retries.
	ErrMaxRetriesExceeded = errors.New("rabbitmq: max retries exceeded")

	// ErrNoHandlersRegistered is returned when StartConsume is called without registering any handlers.
	ErrNoHandlersRegistered = errors.New("rabbitmq: no handlers registered, call RegisterHandler before StartConsume")

	// ErrPublishNotConfirmed is returned when a message publish is not confirmed by RabbitMQ.
	ErrPublishNotConfirmed = errors.New("rabbitmq: message publish was not confirmed by broker")

	// ErrPublishConfirmTimeout is returned when waiting for publish confirmation times out.
	ErrPublishConfirmTimeout = errors.New("rabbitmq: timeout waiting for publish confirmation")
)