net.sf.hajdbc.distributable

Class DistributableStateManager

java.lang.Object

net.sf.hajdbc.distributable.AbstractMembershipListener

net.sf.hajdbc.distributable.DistributableStateManager

All Implemented Interfaces:

java.util.EventListener, DatabaseActivationListener, DatabaseDeactivationListener, Lifecycle, StateManager, org.jgroups.blocks.RequestHandler, org.jgroups.MembershipListener, org.jgroups.MessageListener

public class DistributableStateManager
extends AbstractMembershipListener
implements StateManager, org.jgroups.MessageListener, org.jgroups.blocks.RequestHandler

StateManager implementation that broadcasts database activations and deactivations to other group members and retrieves initial state from another group member.

Author:

Paul Ferraro

Field Summary

Fields inherited from class net.sf.hajdbc.distributable.AbstractMembershipListener

channel

Constructor Summary

Constructors

Constructor and Description
DistributableStateManager(DatabaseCluster<?> databaseCluster, DistributableDatabaseClusterDecorator decorator)

Method Summary

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.

Methods inherited from class net.sf.hajdbc.distributable.AbstractMembershipListener

block, getMembershipSize, isMembershipEmpty, suspect, viewAccepted

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface net.sf.hajdbc.StateManager

isMembershipEmpty

Constructor Detail

DistributableStateManager

public DistributableStateManager(DatabaseCluster<?> databaseCluster,
                                 DistributableDatabaseClusterDecorator decorator)
                          throws java.lang.Exception

Parameters:

databaseCluster -

decorator -

Throws:

java.lang.Exception

Method Detail

handle

public java.lang.Object handle(org.jgroups.Message message)

Specified by:

handle in interface org.jgroups.blocks.RequestHandler

See Also:

RequestHandler.handle(org.jgroups.Message)

getInitialState

public java.util.Set<java.lang.String> getInitialState()

Description copied from interface: StateManager

Returns the initial state of the cluster.

Specified by:

getInitialState in interface StateManager

Returns:

a set of database identifiers, or null, if no initial cluster state was found.

See Also:

StateManager.getInitialState()

activated

public void activated(DatabaseEvent event)

Description copied from interface: DatabaseActivationListener

Triggered after database is successfully activated.

Specified by:

activated in interface DatabaseActivationListener

Parameters:

event - indicates the database that was activated

See Also:

DatabaseActivationListener.activated(net.sf.hajdbc.DatabaseEvent)

deactivated

public void deactivated(DatabaseEvent event)

Description copied from interface: DatabaseDeactivationListener

Triggered after database is successfully deactivated.

Specified by:

deactivated in interface DatabaseDeactivationListener

Parameters:

event - indicates the database that was deactivated

See Also:

DatabaseDeactivationListener.deactivated(net.sf.hajdbc.DatabaseEvent)

start

public void start()
           throws java.lang.Exception

Description copied from interface: Lifecycle

Called upon database cluster start.

Specified by:

start in interface Lifecycle

Throws:

java.lang.Exception - if this service fails to start.

See Also:

Lifecycle.start()

stop

public void stop()

Description copied from interface: Lifecycle

Called when database cluster is stopped.

Specified by:

stop in interface Lifecycle

See Also:

Lifecycle.stop()

memberJoined

protected void memberJoined(org.jgroups.Address address)

Specified by:

memberJoined in class AbstractMembershipListener

See Also:

AbstractMembershipListener.memberJoined(org.jgroups.Address)

memberLeft

protected void memberLeft(org.jgroups.Address address)

Specified by:

memberLeft in class AbstractMembershipListener

See Also:

AbstractMembershipListener.memberLeft(org.jgroups.Address)

getState

public byte[] getState()

Specified by:

getState in interface org.jgroups.MessageListener

See Also:

MessageListener.getState()

setState

public void setState(byte[] state)

Specified by:

setState in interface org.jgroups.MessageListener

See Also:

MessageListener.setState(byte[])

receive

public void receive(org.jgroups.Message message)

Specified by:

receive in interface org.jgroups.MessageListener

See Also:

MessageListener.receive(org.jgroups.Message)