Previously, it wasn't empting the output channel unless new messages were received. This caused multiple messages to be sent until some message was received.