net.sf.hajdbc.state.bdb

Class BerkeleyDBStateManager

java.lang.Object

net.sf.hajdbc.pool.AbstractPoolProvider<T,E>

net.sf.hajdbc.pool.CloseablePoolProvider<com.sleepycat.je.Environment,com.sleepycat.je.DatabaseException>

net.sf.hajdbc.state.bdb.BerkeleyDBStateManager

All Implemented Interfaces:

EventListener, DatabaseClusterListener, DurabilityListener, Lifecycle, PoolProvider<com.sleepycat.je.Environment,com.sleepycat.je.DatabaseException>, SerializedDurabilityListener, StateManager

public class BerkeleyDBStateManager
extends CloseablePoolProvider<com.sleepycat.je.Environment,com.sleepycat.je.DatabaseException>
implements StateManager, SerializedDurabilityListener

Author:

paul

Field Summary

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

CLEAR_LOCAL_STATE

Constructor Summary

Constructors

Constructor and Description
BerkeleyDBStateManager(DatabaseCluster<?,?> cluster, File file, com.sleepycat.je.EnvironmentConfig config, PoolFactory poolFactory)

Method Summary

Methods

Modifier and Type	Method and Description
void	activated(DatabaseEvent event) Triggered after database is successfully activated.
void	afterInvocation(byte[] transactionId, byte phase)
void	afterInvocation(InvocationEvent event)
void	afterInvoker(byte[] transactionId, byte phase, String databaseId, byte[] result)
void	afterInvoker(InvokerEvent event)
void	beforeInvocation(byte[] transactionId, byte phase, byte exceptionType)
void	beforeInvocation(InvocationEvent event)
void	beforeInvoker(byte[] transactionId, byte phase, String databaseId)
void	beforeInvoker(InvokerEvent event)
com.sleepycat.je.Environment	create()
void	deactivated(DatabaseEvent event) Triggered after database is successfully deactivated.
Set<String>	getActiveDatabases()
boolean	isEnabled()
boolean	isValid(com.sleepycat.je.Environment environment)
Map<InvocationEvent,Map<String,InvokerEvent>>	recover()
void	setActiveDatabases(Set<String> databases)
void	start() Called upon database cluster start.
void	stop() Called when database cluster is stopped.

Methods inherited from class net.sf.hajdbc.pool.CloseablePoolProvider

close

Methods inherited from class net.sf.hajdbc.pool.AbstractPoolProvider

getExceptionClass, getProvidedClass

Methods inherited from class java.lang.Object

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

Constructor Detail

BerkeleyDBStateManager

public BerkeleyDBStateManager(DatabaseCluster<?,?> cluster,
                      File file,
                      com.sleepycat.je.EnvironmentConfig config,
                      PoolFactory poolFactory)

Method Detail

start

public void start()

Description copied from interface: Lifecycle

Called upon database cluster start.

Specified by:

start in interface Lifecycle

stop

public void stop()

Description copied from interface: Lifecycle

Called when database cluster is stopped.

Specified by:

stop in interface Lifecycle

getActiveDatabases

public Set<String> getActiveDatabases()

Specified by:

getActiveDatabases in interface StateManager

setActiveDatabases

public void setActiveDatabases(Set<String> databases)

Specified by:

setActiveDatabases in interface StateManager

activated

public void activated(DatabaseEvent event)

Description copied from interface: DatabaseClusterListener

Triggered after database is successfully activated.

Specified by:

activated in interface DatabaseClusterListener

Parameters:

event - indicates the database that was activated

deactivated

public void deactivated(DatabaseEvent event)

Description copied from interface: DatabaseClusterListener

Triggered after database is successfully deactivated.

Specified by:

deactivated in interface DatabaseClusterListener

Parameters:

event - indicates the database that was deactivated

beforeInvocation

public void beforeInvocation(InvocationEvent event)

Specified by:

beforeInvocation in interface DurabilityListener

afterInvocation

public void afterInvocation(InvocationEvent event)

Specified by:

afterInvocation in interface DurabilityListener

beforeInvoker

public void beforeInvoker(InvokerEvent event)

Specified by:

beforeInvoker in interface DurabilityListener

afterInvoker

public void afterInvoker(InvokerEvent event)

Specified by:

afterInvoker in interface DurabilityListener

beforeInvocation

public void beforeInvocation(byte[] transactionId,
                    byte phase,
                    byte exceptionType)

Specified by:

beforeInvocation in interface SerializedDurabilityListener

afterInvocation

public void afterInvocation(byte[] transactionId,
                   byte phase)

Specified by:

afterInvocation in interface SerializedDurabilityListener

beforeInvoker

public void beforeInvoker(byte[] transactionId,
                 byte phase,
                 String databaseId)

Specified by:

beforeInvoker in interface SerializedDurabilityListener

afterInvoker

public void afterInvoker(byte[] transactionId,
                byte phase,
                String databaseId,
                byte[] result)

Specified by:

afterInvoker in interface SerializedDurabilityListener

recover

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

Specified by:

recover in interface StateManager

isEnabled

public boolean isEnabled()

Specified by:

isEnabled in interface StateManager

create

public com.sleepycat.je.Environment create()
                                    throws com.sleepycat.je.DatabaseException

Specified by:

create in interface PoolProvider<com.sleepycat.je.Environment,com.sleepycat.je.DatabaseException>

Throws:

com.sleepycat.je.DatabaseException

See Also:

PoolProvider.create()

isValid

public boolean isValid(com.sleepycat.je.Environment environment)

Specified by:

isValid in interface PoolProvider<com.sleepycat.je.Environment,com.sleepycat.je.DatabaseException>

See Also:

PoolProvider.isValid(java.lang.Object)