class ClusterEventObserver {

    public void broadcast(Object event) {
        if (!getClusterService().isAppFormerClustered()) {
            return;
        }

        ClusterSerializedCDIMessageWrapper wrapper = new ClusterSerializedCDIMessageWrapper(nodeId,
                                                                                            toJSON(event),
                                                                                            event.getClass().getName());

        getClusterService().broadcast(ClusterService.DestinationType.PubSub,
                                      CHANNEL_NAME,
                                      wrapper);
    }

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

}