Class 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
    • Method Summary

      All Methods Instance Methods Concrete Methods 
      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 interface org.apache.activemq.broker.Locker

        keepAlive, setFailIfLocked, setLockable, setLockAcquireSleepInterval, setName
      • Methods inherited from interface org.apache.activemq.Service

        start, stop
    • Constructor Detail

      • BambooAmqClusterLocker

        public BambooAmqClusterLocker()
    • Method Detail

      • 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