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

moar logging

parent aeff807b
No related branches found
No related tags found
No related merge requests found
......@@ -34,6 +34,8 @@ class Connection(object):
Connection created -> state is ST_CONNECTING
.start() called -> state is ST_CONNECTING
connection.open-ok -> state is ST_ONLINE
This logger is talkative mostly on INFO, and regarding connection state
"""
def __init__(self, node_definition, listener_thread):
......@@ -109,7 +111,7 @@ class Connection(object):
else:
break
logger.info('Connected to broker, authentication in progress')
logger.debug('TCP connection established, authentication in progress')
sock.settimeout(0)
sock.send(b'AMQP\x00\x00\x09\x01')
......@@ -198,6 +200,9 @@ class Connection(object):
"""
watch_handled = False # True if ANY watch handled this
if isinstance(frame, AMQPMethodFrame):
logger.debug('Received %s', frame.payload.NAME)
# ==================== process per-channel watches
if frame.channel in self.watches:
watches = self.watches[frame.channel] # a list
......
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