expose the subscription channel on both the queue and the ChannelMessage; change the callbacks on ChannelMessageQueue to take ChannelMessage, to expose that