refactored streamer to pickup only the oldest messages by channel