code: @SuppressWarnings("incomplete-switch")
      public void onPipeConnectionEvent(PipeConnectionEvent event) {
          switch (event.getType()) {
              case CONSUMER_CONNECT_PUSH:
                  if (event.getConsumer() == this) {
                      Map<String, Object> paramMap = event.getParamMap();
                      if (paramMap != null) {
                          mode = (String) paramMap.get("mode");
                      }
                  }
                  break;
          }
      }
docs: Pipe connection event handler
  
  @param event
  Pipe connection event