@Override
    public void forwardEvent(final EventTransferObject<Object> event) {


        eventConnector.forwardEvent(new EventTransferObject<Object>() {
            @Override
            public String channel() {
                return event.channel();
            }

            @Override
            public long id() {
                return event.id();
            }

            @Override
            public Object body() {
                return event.body();
            }

            @Override
            public boolean isSingleton() {
                return true;
            }

            @Override
            public MultiMap<String, String> params() {
                return event.params();
            }

            @Override
            public MultiMap<String, String> headers() {
                return event.headers();
            }

            /* Save a map lookup or building a header map. */
            @Override
            public boolean wasReplicated() {
                return true;
            }

            @SuppressWarnings("EqualsWhichDoesntCheckParameterClass")
            @Override
            public boolean equals(Object obj) {
                //noinspection EqualsBetweenInconvertibleTypes
                return event.equals(obj);
            }

            @Override
            public int hashCode() {
                return event.hashCode();
            }
        });
    }
@Override
    public void forwardEvent(final EventTransferObject<Object> event) {


        eventConnector.forwardEvent(new EventTransferObject<Object>() {
            @Override
            public String channel() {
                return event.channel();
            }

            @Override
            public long id() {
                return event.id();
            }

            @Override
            public Object body() {
                return event.body();
            }

            @Override
            public boolean isSingleton() {
                return true;
            }

            @Override
            public MultiMap<String, String> params() {
                return event.params();
            }

            @Override
            public MultiMap<String, String> headers() {
                return event.headers();
            }

            
            @Override
            public boolean wasReplicated() {
                return true;
            }

            @SuppressWarnings("EqualsWhichDoesntCheckParameterClass")
            @Override
            public boolean equals(Object obj) {
                
                return event.equals(obj);
            }

            @Override
            public int hashCode() {
                return event.hashCode();
            }
        });
    }
@ Override public void forwardEvent ( final EventTransferObject < Object > event ) { eventConnector . forwardEvent ( new EventTransferObject < Object > ( ) { @ Override public String channel ( ) { return event . channel ( ) ; } @ Override public long id ( ) { return event . id ( ) ; } @ Override public Object body ( ) { return event . body ( ) ; } @ Override public boolean isSingleton ( ) { return true ; } @ Override public MultiMap < String , String > params ( ) { return event . params ( ) ; } @ Override public MultiMap < String , String > headers ( ) { return event . headers ( ) ; } /* Save a map lookup or building a header map. */ @ Override public boolean wasReplicated ( ) { return true ; } @ SuppressWarnings ( "EqualsWhichDoesntCheckParameterClass" ) @ Override public boolean equals ( Object obj ) { //noinspection EqualsBetweenInconvertibleTypes return event . equals ( obj ) ; } @ Override public int hashCode ( ) { return event . hashCode ( ) ; } } ) ; }
This message receives an event from a remote call.
This message receives an event from a remote call .