Skip to content
Snippets Groups Projects
Commit 45cdb023 authored by Jan Mach's avatar Jan Mach
Browse files

Fix: Fixed bug in Mentat daemon filer component.

In case empty message was loaded from the message queue error was logged into the log file, but event for fetching next message from the queue was not scheduled, which basically resulted in halting of the message processing.
parent bf4174c4
No related branches found
No related tags found
No related merge requests found
...@@ -265,10 +265,11 @@ class FilerDaemonComponent(pyzenkit.zendaemon.ZenDaemonComponent): # pylint: di ...@@ -265,10 +265,11 @@ class FilerDaemonComponent(pyzenkit.zendaemon.ZenDaemonComponent): # pylint: di
else: else:
daemon.logger.debug("Component '{}': Fetched message '{}'".format(self.cid, mid)) daemon.logger.debug("Component '{}': Fetched message '{}'".format(self.cid, mid))
daemon.queue.schedule(self.EVENT_MSG_PROCESS, {'id': mid, 'data': mdata}) daemon.queue.schedule(self.EVENT_MSG_PROCESS, {'id': mid, 'data': mdata})
if not daemon.is_done():
daemon.queue.schedule(self.EVENT_MSG_NEXT) if not daemon.is_done():
else: daemon.queue.schedule(self.EVENT_MSG_NEXT)
daemon.logger.info("Component '{}': Daemon is in shutdown process, will not fetch any new messages".format(self.cid)) else:
daemon.logger.info("Component '{}': Daemon is in shutdown process, will not fetch any new messages".format(self.cid))
else: else:
if not daemon.is_done(): if not daemon.is_done():
daemon.logger.info("Component '{}': Scheduling next queue check after '{}' seconds".format(self.cid, self.wait_interval)) daemon.logger.info("Component '{}': Scheduling next queue check after '{}' seconds".format(self.cid, self.wait_interval))
......
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