@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);
                    }
                }
            }
        }
    }
@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);
                    }
                }
            }
        }
    }
@ 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 ) ; } } } } }
Flushes the pool used to optimize flushing of IO operations.
Flushes the pool used to optimize flushing of IO operations .