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
This bridge adds as much as possible tolerance into
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
-
Nested Class Summary
Nested Classes -
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionvoidaddMessageListener(String topic, org.eclnt.jsfserver.cluster.IClusterMessageQueueListener listener) voidpublishMessage(String topic, String message) voidremoveMessageListener(String topic, org.eclnt.jsfserver.cluster.IClusterMessageQueueListener listener)
-
Constructor Details
-
MQBridgeClusterMessageQueue
public MQBridgeClusterMessageQueue()
-
-
Method Details
-
publishMessage
- Specified by:
publishMessagein interfaceorg.eclnt.jsfserver.cluster.IClusterMessageQueue
-
addMessageListener
public void addMessageListener(String topic, org.eclnt.jsfserver.cluster.IClusterMessageQueueListener listener) - Specified by:
addMessageListenerin interfaceorg.eclnt.jsfserver.cluster.IClusterMessageQueue
-
removeMessageListener
public void removeMessageListener(String topic, org.eclnt.jsfserver.cluster.IClusterMessageQueueListener listener) - Specified by:
removeMessageListenerin interfaceorg.eclnt.jsfserver.cluster.IClusterMessageQueue
-