implement ChannelMessage / ChannelMessageChannel to illustrate API; PubSubGetAllCorrectOrder shows usage, although it doesn't work yet (order is wrong) - I need to implement sync enqueue