public interface DataflowChannelListener<T>
void
onMessage(T message)
void onMessage(T message)
message