Exceptions

class amqppy.RpcRemoteException

It would be raised in the publisher.Rpc.request() when remote reply fails

class amqppy.ResponseTimeout

It would be raised in the publisher.Rpc.request() when remote reply exceeds its allowed execution time, the timeout.

class amqppy.PublishNotRouted

It would be raised in the publisher.Rpc.request() or publisher.Topic.publish() when there is no consumer listening those Topics or Rpc requests.

class amqppy.ExclusiveQueue

It would be raised in the consumer.Worker.add_topic() or consumer.Worker.add_request() when tries to consume from a queue where there is already a consumer listening. That happens when add_topic or add_request is called with ‘exclusive=True’.

class amqppy.ExchangeNotFound

It will be raised when AMQP Exchange does not exist.

class amqppy.AbortConsume

This exception can be raised by the Topic callback or RPC reply callback. And indicates to amqppy to do not send ACK for that consuming message. For this, is required ‘no_ack=False’ in consumer.Worker.add_topic() or consumer.Worker.add_request()

class amqppy.DeadLetterMessage

This exception can be raised by the Topic callback or RPC reply callback. And indicates to amqppy to move this message is being consumed to the DeadLetter Queue. See: ‘https://www.rabbitmq.com/dlx.html’