We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 4eb0b77 commit 0d6eafbCopy full SHA for 0d6eafb
1 file changed
receptor/protocol.py
@@ -51,9 +51,7 @@ async def watch_queue(self):
51
buffer_obj = buffer_mgr.get_buffer_for_node(self.id, self.receptor)
52
while not self.transport.is_closing():
53
try:
54
- logger.debug("about to wait for a message")
55
msg = await buffer_obj.get()
56
- logger.debug("got a message to send")
57
self.transport.write(msg + DELIM)
58
except Exception:
59
logger.exception("Error received trying to write to %s", self.id)
0 commit comments