class ClusterEventObserver {

    void consumeMessage(Event<Object> eventBus,
                        ClusterSerializedCDIMessageWrapper message) {
        if (!message.getNodeId().equals(nodeId)) {
            try {
                Object event = fromJSON(message);
                eventBus.fire(event);
            } catch (Exception e) {
                LOGGER.error("Error consuming cluster event:  " + e.getMessage());
            }
        }
    }

    public  ClusterEventObserver();
    @Inject public  ClusterEventObserver(Event<Object> eventBus);

}