net.sf.hajdbc.state.distributed

Class DistributedStateManager<Z,D extends Database<Z>>

java.lang.Object

net.sf.hajdbc.state.distributed.DistributedStateManager<Z,D>

All Implemented Interfaces:

EventListener, DatabaseClusterListener, MembershipListener, Stateful, DurabilityListener, Lifecycle, StateCommandContext<Z,D>, StateManager

public class DistributedStateManager<Z,D extends Database<Z>>
extends Object
implements StateManager, StateCommandContext<Z,D>, MembershipListener, Stateful

Author:

Paul Ferraro

Field Summary

Fields inherited from interface net.sf.hajdbc.state.StateManager

CLEAR_LOCAL_STATE

Constructor Summary

Constructors

Constructor and Description
DistributedStateManager(DatabaseCluster<Z,D> cluster, CommandDispatcherFactory dispatcherFactory)

Method Summary

Methods

Modifier and Type	Method and Description
void	activated(DatabaseEvent event) Triggered after database is successfully activated.
void	added(Member member) Indicates that the specified member was added to the group.
void	afterInvocation(InvocationEvent event)
void	afterInvoker(InvokerEvent event)
void	beforeInvocation(InvocationEvent event)
void	beforeInvoker(InvokerEvent event)
void	deactivated(DatabaseEvent event) Triggered after database is successfully deactivated.
Set<String>	getActiveDatabases()
DatabaseCluster<Z,D>	getDatabaseCluster()
StateManager	getLocalStateManager()
Map<InvocationEvent,Map<String,InvokerEvent>>	getRemoteInvokers(Remote remote)
boolean	isEnabled()
void	readState(ObjectInput input) Returns the state of this object.
Map<InvocationEvent,Map<String,InvokerEvent>>	recover()
void	removed(Member member) Indicates the the specified member was removed from the group.
void	setActiveDatabases(Set<String> databases)
void	start() Called upon database cluster start.
void	stop() Called when database cluster is stopped.
void	writeState(ObjectOutput output) Sets the state of this object.

Methods inherited from class java.lang.Object

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

Constructor Detail

DistributedStateManager

public DistributedStateManager(DatabaseCluster<Z,D> cluster,
                       CommandDispatcherFactory dispatcherFactory)
                        throws Exception

Throws:

Exception

Method Detail

getActiveDatabases

public Set<String> getActiveDatabases()

Specified by:

getActiveDatabases in interface StateManager

See Also:

StateManager.getActiveDatabases()

setActiveDatabases

public void setActiveDatabases(Set<String> databases)

Specified by:

setActiveDatabases in interface StateManager

See Also:

StateManager.setActiveDatabases(java.util.Set)

activated

public void activated(DatabaseEvent event)

Triggered after database is successfully activated.

Specified by:

activated in interface DatabaseClusterListener

Parameters:

event - indicates the database that was activated

See Also:

DatabaseClusterListener.activated(net.sf.hajdbc.state.DatabaseEvent)

deactivated

public void deactivated(DatabaseEvent event)

Triggered after database is successfully deactivated.

Specified by:

deactivated in interface DatabaseClusterListener

Parameters:

event - indicates the database that was deactivated

See Also:

DatabaseClusterListener.deactivated(net.sf.hajdbc.state.DatabaseEvent)

afterInvocation

public void afterInvocation(InvocationEvent event)

Specified by:

afterInvocation in interface DurabilityListener

See Also:

DurabilityListener.afterInvocation(net.sf.hajdbc.durability.InvocationEvent)

afterInvoker

public void afterInvoker(InvokerEvent event)

Specified by:

afterInvoker in interface DurabilityListener

See Also:

DurabilityListener.afterInvoker(net.sf.hajdbc.durability.InvokerEvent)

beforeInvocation

public void beforeInvocation(InvocationEvent event)

Specified by:

beforeInvocation in interface DurabilityListener

See Also:

DurabilityListener.beforeInvocation(net.sf.hajdbc.durability.InvocationEvent)

beforeInvoker

public void beforeInvoker(InvokerEvent event)

Specified by:

beforeInvoker in interface DurabilityListener

See Also:

DurabilityListener.beforeInvoker(net.sf.hajdbc.durability.InvokerEvent)

start

public void start()
           throws Exception

Called upon database cluster start.

Specified by:

start in interface Lifecycle

Throws:

Exception - if this service fails to start.

See Also:

Lifecycle.start()

stop

public void stop()

Called when database cluster is stopped.

Specified by:

stop in interface Lifecycle

See Also:

Lifecycle.stop()

isEnabled

public boolean isEnabled()

Specified by:

isEnabled in interface StateManager

getDatabaseCluster

public DatabaseCluster<Z,D> getDatabaseCluster()

Specified by:

getDatabaseCluster in interface StateCommandContext<Z,D extends Database<Z>>

See Also:

StateCommandContext.getDatabaseCluster()

getLocalStateManager

public StateManager getLocalStateManager()

Specified by:

getLocalStateManager in interface StateCommandContext<Z,D extends Database<Z>>

See Also:

StateCommandContext.getLocalStateManager()

getRemoteInvokers

public Map<InvocationEvent,Map<String,InvokerEvent>> getRemoteInvokers(Remote remote)

Specified by:

getRemoteInvokers in interface StateCommandContext<Z,D extends Database<Z>>

See Also:

StateCommandContext.getRemoteInvokers(net.sf.hajdbc.distributed.Remote)

readState

public void readState(ObjectInput input)
               throws IOException

Returns the state of this object.

Specified by:

readState in interface Stateful

Throws:

IOException

See Also:

Stateful.readState(java.io.ObjectInput)

writeState

public void writeState(ObjectOutput output)
                throws IOException

Sets the state of this object.

Specified by:

writeState in interface Stateful

Throws:

IOException

See Also:

Stateful.writeState(java.io.ObjectOutput)

added

public void added(Member member)

Indicates that the specified member was added to the group.

Specified by:

added in interface MembershipListener

Parameters:

member - the added member

See Also:

MembershipListener.added(net.sf.hajdbc.distributed.Member)

removed

public void removed(Member member)

Indicates the the specified member was removed from the group.

Specified by:

removed in interface MembershipListener

Parameters:

member - the removed member

See Also:

MembershipListener.removed(net.sf.hajdbc.distributed.Member)

recover

public Map<InvocationEvent,Map<String,InvokerEvent>> recover()

Specified by:

recover in interface StateManager

See Also:

StateManager.recover()