From 7ef2990ab5941bd2dd9127f418a7a684faa10333 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Piotr=20Ma=C5=9Blanka?= <piotr.maslanka@henrietta.com.pl>
Date: Sun, 5 Jan 2020 15:31:24 +0100
Subject: [PATCH] debug by CI
---
coolamqp/uplink/handshake.py | 5 +++++
1 file changed, 5 insertions(+)
diff --git a/coolamqp/uplink/handshake.py b/coolamqp/uplink/handshake.py
index 2842d14..a9ba9ee 100644
--- a/coolamqp/uplink/handshake.py
+++ b/coolamqp/uplink/handshake.py
@@ -7,11 +7,13 @@ Provides reactors that can authenticate an AQMP session
import six
import typing as tp
import copy
+import logging
from coolamqp.framing.definitions import ConnectionStart, ConnectionStartOk, \
ConnectionTune, ConnectionTuneOk, ConnectionOpen, ConnectionOpenOk
from coolamqp.framing.frames import AMQPMethodFrame
from coolamqp.uplink.connection.states import ST_ONLINE
from coolamqp import __version__
+
PUBLISHER_CONFIRMS = b'publisher_confirms'
CONSUMER_CANCEL_NOTIFY = b'consumer_cancel_notify'
@@ -37,6 +39,8 @@ CLIENT_DATA = [
WATCHDOG_TIMEOUT = 10
+logger = logging.getLogger(__name__)
+
class Handshaker(object):
"""
@@ -111,6 +115,7 @@ class Handshaker(object):
def on_connection_tune(self, payload # type: coolamqp.framing.base.AMQPPayload
):
+ logger.debug('Responding with ConnectionTuneOk')
self.connection.frame_max = payload.frame_max
self.connection.heartbeat = min(payload.heartbeat, self.heartbeat)
for channel in six.moves.xrange(1, (
--
GitLab