Package org.apache.activemq.broker
Interface Lockable
-
- All Known Implementing Classes:
AbstractKahaDBStore,DataSourceServiceSupport,JDBCPersistenceAdapter,JobSchedulerStoreImpl,JournalPersistenceAdapterFactory,KahaDBPersistenceAdapter,LockableServiceSupport,MultiKahaDBPersistenceAdapter,PersistenceAdapterFactoryBean
public interface LockableA lockable broker resource. UsesLockerto guarantee that only single instance is running
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description LockercreateDefaultLocker()Create a default lockerlonggetLockKeepAlivePeriod()voidsetLocker(Locker locker)Set locker to be usedvoidsetLockKeepAlivePeriod(long lockKeepAlivePeriod)Period (in milliseconds) on whichLocker.keepAlive()should be checkedvoidsetStopOnError(boolean stopOnError)Stop the broker if the locker get an exception while processing lock.voidsetUseLock(boolean useLock)Turn locking on/off on the resource
-
-
-
Method Detail
-
setUseLock
void setUseLock(boolean useLock)
Turn locking on/off on the resource- Parameters:
useLock-
-
setStopOnError
void setStopOnError(boolean stopOnError)
Stop the broker if the locker get an exception while processing lock.- Parameters:
stopOnError-
-
createDefaultLocker
Locker createDefaultLocker() throws IOException
Create a default locker- Returns:
- default locker
- Throws:
IOException
-
setLocker
void setLocker(Locker locker) throws IOException
Set locker to be used- Parameters:
locker-- Throws:
IOException
-
setLockKeepAlivePeriod
void setLockKeepAlivePeriod(long lockKeepAlivePeriod)
Period (in milliseconds) on whichLocker.keepAlive()should be checked- Parameters:
lockKeepAlivePeriod-
-
getLockKeepAlivePeriod
long getLockKeepAlivePeriod()
-
-