Package com.atlassian.bamboo.amq

Class BambooAmqClusterLocker

java.lang.Object
org.apache.activemq.util.ServiceSupport
org.apache.activemq.broker.AbstractLocker
com.atlassian.bamboo.amq.BambooAmqClusterLocker
All Implemented Interfaces:
org.apache.activemq.broker.Locker, org.apache.activemq.Service
public class BambooAmqClusterLocker extends org.apache.activemq.broker.AbstractLocker implements org.apache.activemq.broker.Locker

  • Field Summary

    Fields inherited from class org.apache.activemq.broker.AbstractLocker

    DEFAULT_LOCK_ACQUIRE_SLEEP_INTERVAL, failIfLocked, lockable, lockAcquireSleepInterval, name

  • Constructor Summary

    Constructors
    Constructor
    Description
    BambooAmqClusterLocker()
     

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    configure(org.apache.activemq.store.PersistenceAdapter persistenceAdapter)
     
    protected void
    doStart()
     
    protected void
    doStop(org.apache.activemq.util.ServiceStopper serviceStopper)
     

    Methods inherited from class org.apache.activemq.broker.AbstractLocker

    getLockAcquireSleepInterval, keepAlive, setFailIfLocked, setLockable, setLockAcquireSleepInterval, setName

    Methods inherited from class org.apache.activemq.util.ServiceSupport

    addServiceListener, dispose, isStarted, isStopped, isStopping, postStop, preStart, 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.broker.Locker

    keepAlive, setFailIfLocked, setLockable, setLockAcquireSleepInterval, setName

    Methods inherited from interface org.apache.activemq.Service

    start, stop

  • Constructor Details

    • BambooAmqClusterLocker

      public BambooAmqClusterLocker()

  • Method Details

    • configure

      public void configure(org.apache.activemq.store.PersistenceAdapter persistenceAdapter) throws IOException
      Specified by:
      configure in interface org.apache.activemq.broker.Locker
      Throws:
      IOException

    • doStop

      protected void doStop(org.apache.activemq.util.ServiceStopper serviceStopper)
      Specified by:
      doStop in class org.apache.activemq.util.ServiceSupport

    • doStart

      protected void doStart() throws Exception
      Specified by:
      doStart in class org.apache.activemq.util.ServiceSupport
      Throws:
      Exception