Yuxi Fu

It's not always reproducible. Basically this is what I do: ```python def consume_until_empty_or_expire(self, channel, callback=None, expires_sec=0, echo=False): """ consume the messages in the queue until no message available callback: func(event_data)...