qbit/core/src/main/java/io/advantageous/qbit/events/impl/EventConnectorHub.java
@Override
    public void forwardEvent(final EventTransferObject<Object> event) {

        if (debug) logger.debug("forwardEvent " + event.channel() + " size " + eventConnectors.size());

        for (int index = 0; index < eventConnectors.size(); index++) {

            EventConnector eventConnector = null;
            try {
                eventConnector = eventConnectors.get(index);
                eventConnector.forwardEvent(event);
            } catch (Exception ex) {
                logger.error("problem sending event to event connector", ex);

                if (eventConnector instanceof RemoteTCPClientProxy) {
                    if (!((RemoteTCPClientProxy) eventConnector).connected()) {
                        eventConnectors.remove(eventConnector);
                    }
                }
            }
        }


        if (debug) logger.debug("forwardEvent done " + event.channel());
    }
@Override
    public void forwardEvent(final EventTransferObject<Object> event) {

        if (debug) logger.debug("forwardEvent " + event.channel() + " size " + eventConnectors.size());

        for (int index = 0; index < eventConnectors.size(); index++) {

            EventConnector eventConnector = null;
            try {
                eventConnector = eventConnectors.get(index);
                eventConnector.forwardEvent(event);
            } catch (Exception ex) {
                logger.error("problem sending event to event connector", ex);

                if (eventConnector instanceof RemoteTCPClientProxy) {
                    if (!((RemoteTCPClientProxy) eventConnector).connected()) {
                        eventConnectors.remove(eventConnector);
                    }
                }
            }
        }


        if (debug) logger.debug("forwardEvent done " + event.channel());
    }
@ Override public void forwardEvent ( final EventTransferObject < Object > event ) { if ( debug ) logger . debug ( "forwardEvent " + event . channel ( ) + " size " + eventConnectors . size ( ) ) ; for ( int index = 0 ; index < eventConnectors . size ( ) ; index ++ ) { EventConnector eventConnector = null ; try { eventConnector = eventConnectors . get ( index ) ; eventConnector . forwardEvent ( event ) ; } catch ( Exception ex ) { logger . error ( "problem sending event to event connector" , ex ) ; if ( eventConnector instanceof RemoteTCPClientProxy ) { if ( ! ( ( RemoteTCPClientProxy ) eventConnector ) . connected ( ) ) { eventConnectors . remove ( eventConnector ) ; } } } } if ( debug ) logger . debug ( "forwardEvent done " + event . channel ( ) ) ; }
Forwards en event to another event system.

@param event event
Forwards en event to another event system .