Added some additional logging for Issue #3.

eandersson · Apr 24, 2015 · 3b4c710 · 3b4c710
1 parent e3d93de
commit 3b4c710
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 1 deletion.
diff --git a/amqpstorm/channel.py b/amqpstorm/channel.py
@@ -249,9 +249,11 @@ def _fetch_message(self):
                 return None
             basic_deliver = self._inbound.pop(0)
             if not isinstance(basic_deliver, pamqp_spec.Basic.Deliver):
+                LOGGER.warning('Received an out-of-order Basic.Deliver frame')
                 return None
             content_header = self._inbound.pop(0)
             if not isinstance(content_header, ContentHeader):
+                LOGGER.warning('Received an out-of-order ContentHeader frame')
                 return None
             body = self._build_message_body(content_header.body_size)
 

diff --git a/examples/basic_get.py b/examples/basic_get.py
@@ -25,7 +25,6 @@ def consumer():
     if result:
         # If we got a message, handle it.
         print('Message:', result['body'])
-        print(result)
 
         # Mark the message as handle.
         channel.basic.ack(delivery_tag=result['method']['delivery_tag'])