From 438bbc1b2927057253b3a221de908ddc51ad65cc Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Piotr=20Ma=C5=9Blanka?= <piotr.maslanka@henrietta.com.pl>
Date: Wed, 31 Mar 2021 19:27:47 +0200
Subject: [PATCH] v1.2.13
---
CHANGELOG.md | 2 ++
coolamqp/__init__.py | 2 +-
coolamqp/tracing.py | 12 ++++++++++--
3 files changed, 13 insertions(+), 3 deletions(-)
diff --git a/CHANGELOG.md b/CHANGELOG.md
index 60e9038..09e24e4 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 538dd8e..b937dee 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 e06a16c..0f7fa62 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):
--
GitLab