org.apache.activemq.store.jdbc.adapter

Class TransactDatabaseLocker

java.lang.Object

org.apache.activemq.store.jdbc.DefaultDatabaseLocker

org.apache.activemq.store.jdbc.adapter.TransactDatabaseLocker

All Implemented Interfaces:

Service, DatabaseLocker

public class TransactDatabaseLocker
extends DefaultDatabaseLocker

Represents an exclusive lock on a database to avoid multiple brokers running against the same logical database.

Field Summary

Fields inherited from class org.apache.activemq.store.jdbc.DefaultDatabaseLocker

connection, dataSource, DEFAULT_LOCK_ACQUIRE_SLEEP_INTERVAL, exceptionHandler, lockAcquireSleepInterval, lockCreateStatement, lockUpdateStatement, queryTimeout, statements, stopping

Constructor Summary

Constructors

Constructor and Description
TransactDatabaseLocker()
TransactDatabaseLocker(JDBCPersistenceAdapter persistenceAdapter)

Method Summary

Methods

Modifier and Type	Method and Description
void	start()

Methods inherited from class org.apache.activemq.store.jdbc.DefaultDatabaseLocker

getExceptionHandler, getLockAcquireSleepInterval, getQueryTimeout, keepAlive, setExceptionHandler, setLockAcquireSleepInterval, setPersistenceAdapter, setQueryTimeout, stop

Methods inherited from class java.lang.Object

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

Constructor Detail

TransactDatabaseLocker

public TransactDatabaseLocker()

TransactDatabaseLocker

public TransactDatabaseLocker(JDBCPersistenceAdapter persistenceAdapter)
                       throws java.io.IOException

Throws:

java.io.IOException

Method Detail

start

public void start()
           throws java.lang.Exception

Specified by:

start in interface Service

Overrides:

start in class DefaultDatabaseLocker

Throws:

java.lang.Exception