Skip to content

Commit 02ca72b

Browse files
committed
AMQP: Fix exceptions in log statements
1 parent 6983315 commit 02ca72b

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

msgflo/msgflo.py

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -168,7 +168,7 @@ def _send_discovery(self, channel, definition):
168168
}
169169
msg = haigha_Message(json.dumps(m))
170170
channel.basic.publish(msg, '', 'fbp')
171-
logger.debug('sent discovery message', msg)
171+
logger.debug('sent discovery message')
172172
return
173173

174174
def _setup_queue(self, part, channel, direction, port):
@@ -191,10 +191,10 @@ def handle_input(msg):
191191
if 'in' in direction:
192192
channel.queue.declare(queue)
193193
channel.basic.consume(queue=queue, consumer=handle_input, no_ack=False)
194-
logger.debug('subscribed to', queue)
194+
logger.debug('subscribed to %s' % queue)
195195
else:
196196
channel.exchange.declare(queue, 'fanout')
197-
logger.debug('created outqueue')
197+
logger.debug('created outqueue %s' % queue)
198198

199199
class MqttEngine(Engine):
200200
def __init__(self, broker):

0 commit comments

Comments
 (0)