code: @Override
      public void flush() {
  
  
          for (int index = 0; index < eventConnectors.size(); index++) {
  
              EventConnector eventConnector = null;
              try {
                  eventConnector = eventConnectors.get(index);
                  if (eventConnector instanceof ClientProxy) {
                      ServiceProxyUtils.flushServiceProxy(eventConnector);
                  } else {
                      eventConnector.flush();
                  }
              } catch (Exception ex) {
                  logger.debug("problem sending event to event connector", ex);
                  if (eventConnector instanceof RemoteTCPClientProxy) {
                      if (!((RemoteTCPClientProxy) eventConnector).connected()) {
  
                          eventConnectors.remove(eventConnector);
                      }
                  }
              }
          }
      }
docs: Flushes the pool used to optimize flushing of IO operations.