Just wonder is there a special directive that we can configure event_handler to consume message periodically
def polling(self, dummy_data):
result = check_status()
if not result:
As you can see, the event handler will consume one message at a time from queueA every 60 seconds.
Currently, i use this logic, there will be a recursive firing of alot of events till check_status return false. What we do not want is to implement a database logic in order to support this.
Any help will be useful