org.apache.qpid.server.store.berkeleydb

Class StandardEnvironmentFacade

java.lang.Object

org.apache.qpid.server.store.berkeleydb.StandardEnvironmentFacade

All Implemented Interfaces:

EnvironmentFacade

public class StandardEnvironmentFacade
extends Object
implements EnvironmentFacade

Field Summary

Fields inherited from interface org.apache.qpid.server.store.berkeleydb.EnvironmentFacade

CACHE_MODE_DEFAULT, CACHE_MODE_PROPERTY_NAME, DEFAULT_LOG_HANDLER_CLEANER_PROTECTED_FILES_LIMIT, ENVCONFIG_DEFAULTS, LOG_HANDLER_CLEANER_PROTECTED_FILES_LIMIT_PROPERTY_NAME

Constructor Summary

Constructors

Constructor and Description
StandardEnvironmentFacade(StandardEnvironmentConfiguration configuration)

Method Summary

Modifier and Type	Method and Description
com.sleepycat.je.Transaction	beginTransaction(com.sleepycat.je.TransactionConfig transactionConfig)
void	checkpoint(boolean force)
int	cleanLog()
com.sleepycat.je.Database	clearDatabase(String name, com.sleepycat.je.DatabaseConfig databaseConfig)
void	close()
void	closeDatabase(String name)
void	commit(com.sleepycat.je.Transaction tx, boolean syncCommit)
<X> com.google.common.util.concurrent.ListenableFuture<X>	commitAsync(com.sleepycat.je.Transaction tx, X val)
void	flushLog()
void	flushLogFailed(RuntimeException e)
Map<String,Object>	getDatabaseStatistics(String database, boolean reset)
Map<String,Map<String,Object>>	getEnvironmentStatistics(boolean reset)
long	getTotalLogSize()
Map<String,Object>	getTransactionStatistics(boolean reset)
RuntimeException	handleDatabaseException(String contextMessage, RuntimeException e)
com.sleepycat.je.Database	openDatabase(String name, com.sleepycat.je.DatabaseConfig databaseConfig)
com.sleepycat.je.Sequence	openSequence(com.sleepycat.je.Database database, com.sleepycat.je.DatabaseEntry sequenceKey, com.sleepycat.je.SequenceConfig sequenceConfig)
void	reduceSizeOnDisk()
void	setCacheSize(long cacheSize)
void	updateMutableConfig(ConfiguredObject<?> object)
void	upgradeIfNecessary(ConfiguredObject<?> parent)

Methods inherited from class java.lang.Object

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

Constructor Detail

StandardEnvironmentFacade

public StandardEnvironmentFacade(StandardEnvironmentConfiguration configuration)

Method Detail

beginTransaction

public com.sleepycat.je.Transaction beginTransaction(com.sleepycat.je.TransactionConfig transactionConfig)

Specified by:

beginTransaction in interface EnvironmentFacade

commit

public void commit(com.sleepycat.je.Transaction tx,
                   boolean syncCommit)

Specified by:

commit in interface EnvironmentFacade

commitAsync

public <X> com.google.common.util.concurrent.ListenableFuture<X> commitAsync(com.sleepycat.je.Transaction tx,
                                                                             X val)

Specified by:

commitAsync in interface EnvironmentFacade

close

public void close()

Specified by:

close in interface EnvironmentFacade

getTotalLogSize

public long getTotalLogSize()

Specified by:

getTotalLogSize in interface EnvironmentFacade

reduceSizeOnDisk

public void reduceSizeOnDisk()

Specified by:

reduceSizeOnDisk in interface EnvironmentFacade

flushLog

public void flushLog()

Specified by:

flushLog in interface EnvironmentFacade

setCacheSize

public void setCacheSize(long cacheSize)

Specified by:

setCacheSize in interface EnvironmentFacade

flushLogFailed

public void flushLogFailed(RuntimeException e)

Specified by:

flushLogFailed in interface EnvironmentFacade

updateMutableConfig

public void updateMutableConfig(ConfiguredObject<?> object)

Specified by:

updateMutableConfig in interface EnvironmentFacade

cleanLog

public int cleanLog()

Specified by:

cleanLog in interface EnvironmentFacade

checkpoint

public void checkpoint(boolean force)

Specified by:

checkpoint in interface EnvironmentFacade

getEnvironmentStatistics

public Map<String,Map<String,Object>> getEnvironmentStatistics(boolean reset)

Specified by:

getEnvironmentStatistics in interface EnvironmentFacade

getDatabaseStatistics

public Map<String,Object> getDatabaseStatistics(String database,
                                                boolean reset)

Specified by:

getDatabaseStatistics in interface EnvironmentFacade

getTransactionStatistics

public Map<String,Object> getTransactionStatistics(boolean reset)

Specified by:

getTransactionStatistics in interface EnvironmentFacade

upgradeIfNecessary

public void upgradeIfNecessary(ConfiguredObject<?> parent)

Specified by:

upgradeIfNecessary in interface EnvironmentFacade

handleDatabaseException

public RuntimeException handleDatabaseException(String contextMessage,
                                                RuntimeException e)

Specified by:

handleDatabaseException in interface EnvironmentFacade

openDatabase

public com.sleepycat.je.Database openDatabase(String name,
                                              com.sleepycat.je.DatabaseConfig databaseConfig)

Specified by:

openDatabase in interface EnvironmentFacade

clearDatabase

public com.sleepycat.je.Database clearDatabase(String name,
                                               com.sleepycat.je.DatabaseConfig databaseConfig)

Specified by:

clearDatabase in interface EnvironmentFacade

openSequence

public com.sleepycat.je.Sequence openSequence(com.sleepycat.je.Database database,
                                              com.sleepycat.je.DatabaseEntry sequenceKey,
                                              com.sleepycat.je.SequenceConfig sequenceConfig)

Specified by:

openSequence in interface EnvironmentFacade

closeDatabase

public void closeDatabase(String name)

Specified by:

closeDatabase in interface EnvironmentFacade