Message Objects - kombu.message

kombu.transport.message

Message class.

class kombu.message.Message(channel, body=None, delivery_tag=None, content_type=None, content_encoding=None, delivery_info={}, properties=None, headers=None, postencode=None, accept=None, **kwargs)

Base class for received messages.

exception MessageStateError

The message has already been acknowledged.

Message.accept

Message.ack()

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.

Message.ack_log_error(logger, errors)

Message.acknowledged

Set to true if the message has been acknowledged.

Message.body

Message.channel

Message.content_encoding

Message.content_type

Message.decode()

Deserialize the message body, returning the original python structure sent by the publisher.

Message.delivery_info

Message.delivery_tag

Message.errors = None

Message.headers

Message.payload

The decoded message body.

Message.properties

Message.reject(requeue=False)

Reject this message.

The message will be discarded by the server.

Raises:MessageStateError – If the message has already been acknowledged/requeued/rejected.

Message.reject_log_error(logger, errors, requeue=False)

Message.requeue()

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.