Class TransactDatabaseLocker
- java.lang.Object
-
- org.apache.activemq.util.ServiceSupport
-
- org.apache.activemq.broker.AbstractLocker
-
- org.apache.activemq.store.jdbc.AbstractJDBCLocker
-
- org.apache.activemq.store.jdbc.DefaultDatabaseLocker
-
- org.apache.activemq.store.jdbc.adapter.TransactDatabaseLocker
-
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, exceptionHandler, lockCreateStatement, lockUpdateStatement
-
Fields inherited from class org.apache.activemq.store.jdbc.AbstractJDBCLocker
createTablesOnStartup, dataSource, jdbcAdapter, queryTimeout
-
Fields inherited from class org.apache.activemq.broker.AbstractLocker
DEFAULT_LOCK_ACQUIRE_SLEEP_INTERVAL, failIfLocked, lockable, lockAcquireSleepInterval, name
-
-
Constructor Summary
Constructors Constructor Description TransactDatabaseLocker()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
doStart()
-
Methods inherited from class org.apache.activemq.store.jdbc.DefaultDatabaseLocker
doStop, getExceptionHandler, getLockAcquireSleepInterval, keepAlive, setExceptionHandler, setLockAcquireSleepInterval
-
Methods inherited from class org.apache.activemq.store.jdbc.AbstractJDBCLocker
close, close, configure, getConnection, getQueryTimeout, getStatements, preStart, setCreateTablesOnStartup, setDataSource, setQueryTimeout, setQueryTimeout, setStatements
-
Methods inherited from class org.apache.activemq.broker.AbstractLocker
setFailIfLocked, setLockable, setName
-
Methods inherited from class org.apache.activemq.util.ServiceSupport
addServiceListener, dispose, isStarted, isStopped, isStopping, postStop, removeServiceListener, start, stop
-
-
-
-
Method Detail
-
doStart
public void doStart() throws Exception
- Overrides:
doStart
in classDefaultDatabaseLocker
- Throws:
Exception
-
-