public class DistributableStateManager extends AbstractMembershipListener implements StateManager, org.jgroups.MessageListener, org.jgroups.blocks.RequestHandler
channel
Constructor and Description |
---|
DistributableStateManager(DatabaseCluster<?> databaseCluster,
DistributableDatabaseClusterDecorator decorator) |
Modifier and Type | Method and Description |
---|---|
void |
activated(DatabaseEvent event)
Triggered after database is successfully activated.
|
void |
deactivated(DatabaseEvent event)
Triggered after database is successfully deactivated.
|
java.util.Set<java.lang.String> |
getInitialState()
Returns the initial state of the cluster.
|
byte[] |
getState() |
java.lang.Object |
handle(org.jgroups.Message message) |
protected void |
memberJoined(org.jgroups.Address address) |
protected void |
memberLeft(org.jgroups.Address address) |
void |
receive(org.jgroups.Message message) |
void |
setState(byte[] state) |
void |
start()
Called upon database cluster start.
|
void |
stop()
Called when database cluster is stopped.
|
block, getMembershipSize, isMembershipEmpty, suspect, viewAccepted
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
isMembershipEmpty
public DistributableStateManager(DatabaseCluster<?> databaseCluster, DistributableDatabaseClusterDecorator decorator) throws java.lang.Exception
databaseCluster
- decorator
- java.lang.Exception
public java.lang.Object handle(org.jgroups.Message message)
handle
in interface org.jgroups.blocks.RequestHandler
RequestHandler.handle(org.jgroups.Message)
public java.util.Set<java.lang.String> getInitialState()
StateManager
getInitialState
in interface StateManager
StateManager.getInitialState()
public void activated(DatabaseEvent event)
DatabaseActivationListener
activated
in interface DatabaseActivationListener
event
- indicates the database that was activatedDatabaseActivationListener.activated(net.sf.hajdbc.DatabaseEvent)
public void deactivated(DatabaseEvent event)
DatabaseDeactivationListener
deactivated
in interface DatabaseDeactivationListener
event
- indicates the database that was deactivatedDatabaseDeactivationListener.deactivated(net.sf.hajdbc.DatabaseEvent)
public void start() throws java.lang.Exception
Lifecycle
start
in interface Lifecycle
java.lang.Exception
- if this service fails to start.Lifecycle.start()
public void stop()
Lifecycle
stop
in interface Lifecycle
Lifecycle.stop()
protected void memberJoined(org.jgroups.Address address)
memberJoined
in class AbstractMembershipListener
AbstractMembershipListener.memberJoined(org.jgroups.Address)
protected void memberLeft(org.jgroups.Address address)
memberLeft
in class AbstractMembershipListener
AbstractMembershipListener.memberLeft(org.jgroups.Address)
public byte[] getState()
getState
in interface org.jgroups.MessageListener
MessageListener.getState()
public void setState(byte[] state)
setState
in interface org.jgroups.MessageListener
MessageListener.setState(byte[])
public void receive(org.jgroups.Message message)
receive
in interface org.jgroups.MessageListener
MessageListener.receive(org.jgroups.Message)