Exceptions

class amqpstorm.AMQPError(*args, **kwargs)[source]

General AMQP Error.

Exceptions raised by AMQPStorm are mapped based to the AMQP 0.9.1 specifications (when applicable).

e.g.

except AMQPChannelError as why:
    if why.error_code == 312:
        self.channel.queue.declare(queue_name)
documentation

AMQP Documentation string.

error_code

AMQP Error Code - A 3-digit reply code.

error_type

AMQP Error Type e.g. NOT-FOUND.

class amqpstorm.AMQPConnectionError(*args, **kwargs)[source]

AMQP Connection Error.

class amqpstorm.AMQPChannelError(*args, **kwargs)[source]

AMQP Channel Error.

class amqpstorm.AMQPMessageError(*args, **kwargs)[source]

AMQP Message Error.

class amqpstorm.AMQPInvalidArgument(*args, **kwargs)[source]

AMQP Argument Error.