diff --git a/CHANGELOG.md b/CHANGELOG.md index 60e90388b72f563bb15ced09fe3c949f02d05cea..09e24e4065a8cf9100fe105f21a1da2f47b12331 100644 --- a/CHANGELOG.md +++ b/CHANGELOG.md @@ -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` diff --git a/coolamqp/__init__.py b/coolamqp/__init__.py index 538dd8e6d562135edd2208926c4b35d7b32178d6..b937deeb959e1af6663f300501ebfebd6c8dd062 100644 --- a/coolamqp/__init__.py +++ b/coolamqp/__init__.py @@ -1 +1 @@ -__version__ = '1.2.13a1' +__version__ = '1.2.13' diff --git a/coolamqp/tracing.py b/coolamqp/tracing.py index e06a16c7c9d1cb9a0369caa7e39294de5c22dfc2..0f7fa628ddafa6586a6549d49b5ca77a9ca7374a 100644 --- a/coolamqp/tracing.py +++ b/coolamqp/tracing.py @@ -1,5 +1,7 @@ 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):