qbit-ext/eventbus-replicator/src/main/java/io/advantageous/qbit/eventbus/EventRemoteReplicatorService.java
@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();
            }

            /* 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.