public class JavaGroupsCommunicator extends Communicator implements org.jgroups.blocks.NotificationBus.Consumer
Modifier and Type | Field and Description |
---|---|
static java.lang.String |
BUS_NAME |
static java.lang.String |
CHANNEL_PROPERTIES |
Constructor and Description |
---|
JavaGroupsCommunicator(java.lang.String properties) |
Modifier and Type | Method and Description |
---|---|
protected void |
finalize() |
java.io.Serializable |
getCache() |
void |
handleNotification(java.io.Serializable object) |
void |
memberJoined(org.jgroups.Address who) |
void |
memberLeft(org.jgroups.Address who) |
protected void |
send(CacheNotification notification)
Implement this to send a cache notification over the communications layer.
|
void |
shutDown()
Called by the cache manager to shut down the communicator.
|
getGroupName, getManager, receive, setGroupName, setManager
public static final java.lang.String BUS_NAME
public static final java.lang.String CHANNEL_PROPERTIES
public JavaGroupsCommunicator(java.lang.String properties)
public void shutDown()
Communicator
shutDown
in class Communicator
protected void finalize() throws java.lang.Throwable
finalize
in class java.lang.Object
java.lang.Throwable
protected final void send(CacheNotification notification)
Communicator
send
in class Communicator
notification
- the cache notification to send.public java.io.Serializable getCache()
getCache
in interface org.jgroups.blocks.NotificationBus.Consumer
public void handleNotification(java.io.Serializable object)
handleNotification
in interface org.jgroups.blocks.NotificationBus.Consumer
public void memberJoined(org.jgroups.Address who)
memberJoined
in interface org.jgroups.blocks.NotificationBus.Consumer
public void memberLeft(org.jgroups.Address who)
memberLeft
in interface org.jgroups.blocks.NotificationBus.Consumer