handling buffer errors in protocol more specificially

Signed-off-by: Jesse Jaggars <jjaggars@redhat.com>

Author: jhjaggars

receptor/protocol.py

@@ -52,6 +52,11 @@ async def watch_queue(self):
         while not self.transport.is_closing():
             try:
                 msg = await buffer_obj.get()
+            except Exception:
+                logger.exception("Unhandled error when fetch from buffer for %s", self.id)
+                continue
+
+            try:
                 self.transport.write(msg + DELIM)
             except Exception:
                 logger.exception("Error received trying to write to %s", self.id)