code: private void fireOnFlow(ChannelEvent e) {
          List<EventListener> listeners = changes.getListenerList(AMQP);
          for (EventListener listener : listeners) {
              ChannelListener amqpListener = (ChannelListener)listener;
              amqpListener.onFlow(e);
          }
      }
docs: Fired when Flow is On/Off
  
  @param e