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

java.lang.Object
  extended by org.apache.activemq.store.jdbc.DefaultDatabaseLocker
      extended by 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.

Version:
$Revision: 818910 $

Field Summary
 
Fields inherited from class org.apache.activemq.store.jdbc.DefaultDatabaseLocker
connection, dataSource, DEFAULT_LOCK_ACQUIRE_SLEEP_INTERVAL, exceptionHandler, lockAcquireSleepInterval, statements, stopping
 
Constructor Summary
TransactDatabaseLocker()
           
TransactDatabaseLocker(JDBCPersistenceAdapter persistenceAdapter)
           
 
Method Summary
 void start()
           
 
Methods inherited from class org.apache.activemq.store.jdbc.DefaultDatabaseLocker
getExceptionHandler, getLockAcquireSleepInterval, keepAlive, setExceptionHandler, setLockAcquireSleepInterval, setPersistenceAdapter, 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 IOException
Throws:
IOException
Method Detail

start

public void start()
           throws Exception
Specified by:
start in interface Service
Overrides:
start in class DefaultDatabaseLocker
Throws:
Exception


Copyright © 2005-2011 Apache Software Foundation. All Rights Reserved.