We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 058b81a commit 3a3bcd3Copy full SHA for 3a3bcd3
msgflo/msgflo.py
@@ -267,6 +267,7 @@ def run(self):
267
self._message_pump_greenlet = gevent.spawn(self._message_pump_greenthread)
268
269
def _send(self, outport, data):
270
+ logger.debug('Participant sent on %s' % outport)
271
ports = self.participant.definition['outports']
272
serialized = json.dumps(data)
273
port = [p for p in ports if outport == p['id']][0]
@@ -334,6 +335,7 @@ def notify():
334
335
msg.json = e
336
msg.data = msg.buffer
337
338
+ logger.debug('Delivering message to %s' % port)
339
self.participant.process(port, msg)
340
341
gevent.spawn(notify)
0 commit comments