code: protected void fireConsumerConnectionEvent(IConsumer consumer, PipeConnectionEvent.EventType type, Map<String, Object> paramMap) {
          firePipeConnectionEvent(PipeConnectionEvent.build(this, type, consumer, paramMap));
      }
docs: Broadcast consumer connection event
  
  @param consumer
  Consumer that has connected
  @param type
  Event type
  @param paramMap
  Parameters passed with connection