Base transport interface.
Base class for received messages.
The decoded message body.
Set to true if the message has been acknowledged.
Acknowledge this message as being processed., This will remove the message from the queue.
Raises MessageStateError: | |
---|---|
If the message has already been acknowledged/requeued/rejected. |
Reject this message.
The message will be discarded by the server.
Raises MessageStateError: | |
---|---|
If the message has already been acknowledged/requeued/rejected. |
Reject this message and put it back on the queue.
You must not use this method as a means of selecting messages to process.
Raises MessageStateError: | |
---|---|
If the message has already been acknowledged/requeued/rejected. |
Deserialize the message body, returning the original python structure sent by the publisher.
Base class for transports.
The Connection owning this instance.
Default port used when no port has been specified.
Optional list of connection related exceptions that can be recovered from, but where the connection must be closed and re-established first.
If not defined then all connection_errors and channel_errors will be regarded as recoverable, but needing to close the connection first.
Optional list of channel related exceptions that can be automatically recovered from without re-establishing the connection.
Tuple of errors that can happen due to connection failure.
Tuple of errors that can happen due to channel/method failure.