Exceptions

Pika specific exceptions

exception pika.exceptions.AMQPChannelError[source]
exception pika.exceptions.AMQPConnectionError[source]
exception pika.exceptions.AMQPError[source]
exception pika.exceptions.AMQPHeartbeatTimeout[source]

Connection was dropped as result of heartbeat timeout.

exception pika.exceptions.AuthenticationError[source]
exception pika.exceptions.BodyTooLongError[source]
exception pika.exceptions.ChannelClosed(reply_code, reply_text)[source]

The channel closed by client or by broker

property reply_code

NEW in v1.0.0 :rtype: int

property reply_text

NEW in v1.0.0 :rtype: str

exception pika.exceptions.ChannelClosedByBroker(reply_code, reply_text)[source]

Channel.Close from broker; may be passed as reason to channel’s on-closed callback of non-blocking connection adapters or raised by BlockingConnection.

NEW in v1.0.0

exception pika.exceptions.ChannelClosedByClient(reply_code, reply_text)[source]

Channel closed by client upon receipt of Channel.CloseOk; may be passed as reason to channel’s on-closed callback of non-blocking connection adapters, but not raised by BlockingConnection.

NEW in v1.0.0

exception pika.exceptions.ChannelError[source]
exception pika.exceptions.ChannelWrongStateError[source]

Channel is in wrong state for the requested operation.

exception pika.exceptions.ConnectionBlockedTimeout[source]

RabbitMQ-specific: timed out waiting for connection.unblocked.

exception pika.exceptions.ConnectionClosed(reply_code, reply_text)[source]
property reply_code

NEW in v1.0.0 :rtype: int

property reply_text

NEW in v1.0.0 :rtype: str

exception pika.exceptions.ConnectionClosedByBroker(reply_code, reply_text)[source]

Connection.Close from broker.

exception pika.exceptions.ConnectionClosedByClient(reply_code, reply_text)[source]

Connection was closed at request of Pika client.

exception pika.exceptions.ConnectionOpenAborted[source]

Client closed connection while opening.

exception pika.exceptions.ConnectionWrongStateError[source]

Connection is in wrong state for the requested operation.

exception pika.exceptions.ConsumerCancelled[source]
exception pika.exceptions.DuplicateConsumerTag[source]
exception pika.exceptions.DuplicateGetOkCallback[source]
exception pika.exceptions.IncompatibleProtocolError[source]
exception pika.exceptions.InvalidChannelNumber[source]
exception pika.exceptions.InvalidFieldTypeException[source]
exception pika.exceptions.InvalidFrameError[source]
exception pika.exceptions.MethodNotImplemented[source]
exception pika.exceptions.NackError(messages)[source]

This exception is raised when a message published in publisher-acknowledgements mode is Nack’ed by the broker.

Used by BlockingChannel.

exception pika.exceptions.NoFreeChannels[source]
exception pika.exceptions.ProbableAccessDeniedError[source]
exception pika.exceptions.ProbableAuthenticationError[source]
exception pika.exceptions.ProtocolSyntaxError[source]
exception pika.exceptions.ProtocolVersionMismatch[source]
exception pika.exceptions.ReentrancyError[source]

The requested operation would result in unsupported recursion or reentrancy.

Used by BlockingConnection/BlockingChannel

exception pika.exceptions.ShortStringTooLong[source]
exception pika.exceptions.StreamLostError[source]

Stream (TCP) connection lost.

exception pika.exceptions.UnexpectedFrameError[source]
exception pika.exceptions.UnroutableError(messages)[source]

Exception containing one or more unroutable messages returned by broker via Basic.Return.

Used by BlockingChannel.

In publisher-acknowledgements mode, this is raised upon receipt of Basic.Ack from broker; in the event of Basic.Nack from broker, NackError is raised instead

exception pika.exceptions.UnsupportedAMQPFieldException[source]