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 TypeMethodDescriptionvoid
addMessageListener
(String topic, org.eclnt.jsfserver.cluster.IClusterMessageQueueListener listener) void
publishMessage
(String topic, String message) void
removeMessageListener
(String topic, org.eclnt.jsfserver.cluster.IClusterMessageQueueListener listener)
-
Constructor Details
-
MQBridgeClusterMessageQueue
public MQBridgeClusterMessageQueue()
-
-
Method Details
-
publishMessage
- Specified by:
publishMessage
in interfaceorg.eclnt.jsfserver.cluster.IClusterMessageQueue
-
addMessageListener
public void addMessageListener(String topic, org.eclnt.jsfserver.cluster.IClusterMessageQueueListener listener) - Specified by:
addMessageListener
in interfaceorg.eclnt.jsfserver.cluster.IClusterMessageQueue
-
removeMessageListener
public void removeMessageListener(String topic, org.eclnt.jsfserver.cluster.IClusterMessageQueueListener listener) - Specified by:
removeMessageListener
in interfaceorg.eclnt.jsfserver.cluster.IClusterMessageQueue
-