public interface DataflowChannelEventDistributor<T>
void
fireOnMessage(T message)
void fireOnMessage(T message)