4.10.5. Publish to a Headers Exchange
To publish to a headers exchange, pass the name of the exchange to the sender constructor, and add the header keys and value to the message
properties
. For example:
- Python
import sys from qpid.messaging import * conn = Connection("localhost:5672") conn.open() try: ssn = conn.session() txheaders = ssn.sender("amq.match") msg = Message("Headers Exchange message") msg.properties['header1'] = 'value1' txheaders.send(msg) finally: ssn.close()