introduce send message function to subscription handlers. (encapsulate Messages pipe into Conveyor)