Change-Id: I591a2edf7ba9dec2912b9f42a5b6bf17542bd519
Signed-off-by: Yaron Yogev <yaronyogev@gmail.com>
# or it's not intended for env listener to handle,
# leave the message in the queue unless "consume_all" flag is set
if processable and event_data["event_type"] in self.handler.handlers:
- with open("/tmp/listener.log", "a") as f:
- f.write("{}\n".format(event_data))
event_result = self.handle_event(event_data["event_type"],
event_data)
finished_timestamp = stringify_datetime(datetime.datetime.now())