Add support for emitting received message via OutputCollector interface.