public class JGroupsClusteringProvider extends org.jgroups.ReceiverAdapter implements ClusteringProvider, MessageCallback
Modifier and Type | Method and Description |
---|---|
void |
callback(Message message)
Called by the Message Bus every time it processes a message with the
subject this callback is registered for.
|
void |
clusterTransmit(String sessionId,
String subject,
String messageId)
Sends an asynchronous message to the cluster to find if any of the clustered buses are aware of the specified
session and subject.
|
void |
clusterTransmitGlobal(Message message)
Advertises a global message to the entire cluster.
|
static Message |
getErraiMessage(org.jgroups.Message message) |
void |
receive(org.jgroups.Message msg) |
public void receive(org.jgroups.Message msg)
receive
in interface org.jgroups.MessageListener
receive
in class org.jgroups.ReceiverAdapter
public void callback(Message message)
MessageCallback
callback
in interface MessageCallback
message
- The message on the bus. Avoid making changes to this object,
because it will continue to be reused by the framework and the
same Message instance will be passed to other callbacks.public void clusterTransmit(String sessionId, String subject, String messageId)
ClusteringProvider
clusterTransmit
in interface ClusteringProvider
sessionId
- the session ID requested.subject
- the subject requested.public void clusterTransmitGlobal(Message message)
ClusteringProvider
clusterTransmitGlobal
in interface ClusteringProvider
public static Message getErraiMessage(org.jgroups.Message message)
Copyright © 2013-2015 JBoss, a division of Red Hat. All Rights Reserved.