consumer: expose 'In' channel
eventsource: add NewConsumer() and AddConsumer()
Add ConstructEventMessage()