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

java.lang.Object
  extended by org.apache.activemq.util.ServiceSupport
      extended by org.apache.activemq.broker.AbstractLocker
          extended by org.apache.activemq.store.jdbc.AbstractJDBCLocker
              extended by org.apache.activemq.store.jdbc.DefaultDatabaseLocker
                  extended by org.apache.activemq.store.jdbc.adapter.TransactDatabaseLocker
All Implemented Interfaces:
Locker, Service

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, queryTimeout, statements
 
Fields inherited from class org.apache.activemq.broker.AbstractLocker
DEFAULT_LOCK_ACQUIRE_SLEEP_INTERVAL, failIfLocked, lockable, lockAcquireSleepInterval, name
 
Constructor Summary
TransactDatabaseLocker()
           
 
Method Summary
 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, 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
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 
Methods inherited from interface org.apache.activemq.Service
start, stop
 

Constructor Detail

TransactDatabaseLocker

public TransactDatabaseLocker()
Method Detail

doStart

public void doStart()
             throws Exception
Overrides:
doStart in class DefaultDatabaseLocker
Throws:
Exception


Copyright © 2005–2013 The Apache Software Foundation. All rights reserved.