Message

class amqpstorm.Message(channel, auto_decode=True, **message)

RabbitMQ Message object.

ack()

Acknowledge Message.

Raises:
Returns:

app_id

Get AMQP Message attribute: app_id.

Returns:
body

Return the Message Body.

If auto_decode is enabled, the body will automatically be decoded using decode(‘utf-8’) if possible.
Return type:bytes|str|unicode
channel

Return the Channel used by this message.

Return type:Channel
content_encoding

Get AMQP Message attribute: content_encoding.

Returns:
content_type

Get AMQP Message attribute: content_type.

Returns:
correlation_id

Get AMQP Message attribute: correlation_id.

Returns:
static create(channel, body, properties=None)

Create a new Message.

Parameters:
  • channel (Channel) – AMQPStorm Channel
  • body (bytes|str|unicode) – Message payload
  • properties (dict) – Message properties
Return type:

Message

delivery_mode

Get AMQP Message attribute: delivery_mode.

Returns:
delivery_tag

Server-assigned delivery tag.

Return type:int|None
json()

Deserialize the message body, if it is JSON.

Returns:
message_id

Get AMQP Message attribute: message_id.

Returns:
method

Return the Message Method.

If auto_decode is enabled, the any strings will automatically be decoded using decode(‘utf-8’) if possible.
Return type:dict
nack(requeue=True)

Negative Acknowledgement.

Raises:
Parameters:

requeue (bool) – Re-queue the message

priority

Get AMQP Message attribute: priority.

Returns:
properties

Returns the Message Properties.

If auto_decode is enabled, the any strings will automatically be decoded using decode(‘utf-8’) if possible.
Return type:dict
publish(routing_key, exchange='', mandatory=False, immediate=False)

Publish Message.

Parameters:
  • routing_key (str) – Message routing key
  • exchange (str) – The exchange to publish the message to
  • mandatory (bool) – Requires the message is published
  • immediate (bool) – Request immediate delivery
Raises:
Return type:

bool|None

redelivered

Indicates if this message may have been delivered before (but not acknowledged).

Return type:bool|None
reject(requeue=True)

Reject Message.

Raises:
Parameters:

requeue (bool) – Re-queue the message

reply_to

Get AMQP Message attribute: reply_to.

Returns:
timestamp

Get AMQP Message attribute: timestamp.

Returns: