consumer: propagate 'close' event
consumer: pull pause/resume functionality from HighLevelConsumer