Skip to content
Snippets Groups Projects
Commit 438bbc1b authored by Piotr Maślanka's avatar Piotr Maślanka
Browse files

v1.2.13

parent 7cb13dc2
No related branches found
No related tags found
No related merge requests found
......@@ -3,3 +3,5 @@ on GitHub. This file serves to only note what changes
have been made so far, between releases.
# v1.2.13
** bugfix release ** fixed `LoggingFrameTracer`
__version__ = '1.2.13a1'
__version__ = '1.2.13'
import logging
from coolamqp.framing.frames import AMQPMethodFrame
class BaseFrameTracer(object):
"""An abstract do-nothing frame tracer"""
......@@ -30,9 +32,15 @@ class LoggingFrameTracer(BaseFrameTracer):
def on_frame(self, timestamp, frame, direction):
if direction == 'to_client':
self.logger.log(self.log_level, 'RECEIVED %s', frame.payload)
if isinstance(frame, AMQPMethodFrame):
self.logger.log(self.log_level, 'RECEIVED METHOD %s', frame.payload)
else:
self.logger.log(self.log_level, 'RECEIVED %s type %s', frame, type(frame))
else:
self.logger.log(self.log_level, 'SENT %s type %s', frame, type(frame))
if isinstance(frame, AMQPMethodFrame):
self.logger.log(self.log_level, 'SENT METHOD %s', frame.payload)
else:
self.logger.log(self.log_level, 'SENT %s type %s', frame, type(frame))
class HoldingFrameTracer(BaseFrameTracer):
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment