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, setManagerpublic static final java.lang.String BUS_NAME
public static final java.lang.String CHANNEL_PROPERTIES
public JavaGroupsCommunicator(java.lang.String properties)
public void shutDown()
CommunicatorshutDown in class Communicatorprotected void finalize()
throws java.lang.Throwable
finalize in class java.lang.Objectjava.lang.Throwableprotected final void send(CacheNotification notification)
Communicatorsend in class Communicatornotification - the cache notification to send.public java.io.Serializable getCache()
getCache in interface org.jgroups.blocks.NotificationBus.Consumerpublic void handleNotification(java.io.Serializable object)
handleNotification in interface org.jgroups.blocks.NotificationBus.Consumerpublic void memberJoined(org.jgroups.Address who)
memberJoined in interface org.jgroups.blocks.NotificationBus.Consumerpublic void memberLeft(org.jgroups.Address who)
memberLeft in interface org.jgroups.blocks.NotificationBus.Consumer