Skip to content

Message Information

Use MQMessage when you need access to MQ-specific metadata or the wrapped raw message.

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
from faststream import Context

from faststream_mq import MQBroker, MQMessage

broker = MQBroker(queue_manager="QM1")


@broker.subscriber("orders.incoming")
async def handle(
    body: dict,
    msg: MQMessage,
    correlation_id: str | None = Context("message.correlation_id"),
) -> None:
    print(body)
    print(msg.raw_message.queue)
    print(correlation_id)

Useful fields

  • message_id
  • correlation_id
  • headers
  • reply_to
  • raw_message.queue