Merge pull request #1301 from pika/mk-message-metadata-access-example

Demonstrate how to access consumer metadata
pika · Jan 26, 2021 · adf89f3 · adf89f3
2 parents fbe3c41 + f0d897f
commit adf89f3
Showing 1 changed file with 4 additions and 3 deletions.
diff --git a/examples/consume.py b/examples/consume.py
@@ -7,12 +7,13 @@
               '-35s %(lineno) -5d: %(message)s')
 LOGGER = logging.getLogger(__name__)
 
-logging.basicConfig(level=logging.DEBUG, format=LOG_FORMAT)
+logging.basicConfig(level=logging.INFO, format=LOG_FORMAT)
 
 
-def on_message(chan, method_frame, _header_frame, body, userdata=None):
+def on_message(chan, method_frame, header_frame, body, userdata=None):
     """Called when a message is received. Log message and ack it."""
-    LOGGER.info('Userdata: %s Message body: %s', userdata, body)
+    LOGGER.info('Delivery properties: %s, message metadata: %s', method_frame, header_frame)
+    LOGGER.info('Userdata: %s, message body: %s', userdata, body)
     chan.basic_ack(delivery_tag=method_frame.delivery_tag)