protected void fireConsumerConnectionEvent ( IConsumer consumer , PipeConnectionEvent . EventType type , Map < String , Object > paramMap ) { firePipeConnectionEvent ( PipeConnectionEvent . build ( this , type , consumer , paramMap ) ) ; }
Broadcast consumer connection event