Class MQBridgeClusterMessageQueue

java.lang.Object
org.eclnt.ccee.mq.clustermessagequeue.MQBridgeClusterMessageQueue
All Implemented Interfaces:
org.eclnt.jsfserver.cluster.IClusterMessageQueue

public class MQBridgeClusterMessageQueue extends Object implements org.eclnt.jsfserver.cluster.IClusterMessageQueue
Bridge between IClusterMessageQueue processing and actual IMessageQueue processing. The cluster processing is an interface defined in elcntjsferver-artifact - which is now mapped to the physical executeion of the messaging.

This bridge adds as much as possible tolerance into
  • Constructor Details

    • MQBridgeClusterMessageQueue

      public MQBridgeClusterMessageQueue()
  • Method Details

    • publishMessage

      public void publishMessage(String topic, String message)
      Specified by:
      publishMessage in interface org.eclnt.jsfserver.cluster.IClusterMessageQueue
    • addMessageListener

      public void addMessageListener(String topic, org.eclnt.jsfserver.cluster.IClusterMessageQueueListener listener)
      Specified by:
      addMessageListener in interface org.eclnt.jsfserver.cluster.IClusterMessageQueue
    • removeMessageListener

      public void removeMessageListener(String topic, org.eclnt.jsfserver.cluster.IClusterMessageQueueListener listener)
      Specified by:
      removeMessageListener in interface org.eclnt.jsfserver.cluster.IClusterMessageQueue