public class FileLockClusterService extends AbstractCamelClusterService<FileLockClusterView>
CamelClusterService.Selectorshutdown, shuttingdown, started, starting, stopped, stopping, suspended, suspending| Constructor and Description |
|---|
FileLockClusterService() |
| Modifier and Type | Method and Description |
|---|---|
protected FileLockClusterView |
createView(String namespace) |
protected void |
doStop()
Implementations override this method to support customized start/stop.
|
long |
getAcquireLockDelay() |
TimeUnit |
getAcquireLockDelayUnit() |
long |
getAcquireLockInterval() |
TimeUnit |
getAcquireLockIntervalUnit() |
String |
getRoot() |
void |
setAcquireLockDelay(long acquireLockDelay)
The time to wait before starting to try to acquire lock, default 1.
|
void |
setAcquireLockDelay(long pollDelay,
TimeUnit pollDelayUnit) |
void |
setAcquireLockDelayUnit(TimeUnit acquireLockDelayUnit)
The time unit fo the acquireLockDelay, default to TimeUnit.SECONDS.
|
void |
setAcquireLockInterval(long acquireLockInterval)
The time to wait between attempts to try to acquire lock, default 10.
|
void |
setAcquireLockInterval(long pollInterval,
TimeUnit pollIntervalUnit) |
void |
setAcquireLockIntervalUnit(TimeUnit acquireLockIntervalUnit)
The time unit fo the acquireLockInterva, default to TimeUnit.SECONDS.
|
void |
setRoot(String root)
Sets the root path.
|
doStart, getAttributes, getCamelContext, getId, getNamespaces, getOrder, getView, isLeader, releaseView, setAttribute, setAttributes, setCamelContext, setId, setOrder, startView, stopViewdoResume, doShutdown, doSuspend, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isStoppingOrStopped, isSuspended, isSuspending, isSuspendingOrSuspended, resume, shutdown, start, stop, suspendclone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitunwrappublic FileLockClusterService()
protected FileLockClusterView createView(String namespace) throws Exception
createView in class AbstractCamelClusterService<FileLockClusterView>Exceptionpublic long getAcquireLockDelay()
public void setAcquireLockDelay(long acquireLockDelay)
public void setAcquireLockDelay(long pollDelay, TimeUnit pollDelayUnit)
public TimeUnit getAcquireLockDelayUnit()
public void setAcquireLockDelayUnit(TimeUnit acquireLockDelayUnit)
public long getAcquireLockInterval()
public void setAcquireLockInterval(long acquireLockInterval)
public void setAcquireLockInterval(long pollInterval, TimeUnit pollIntervalUnit)
public TimeUnit getAcquireLockIntervalUnit()
public void setAcquireLockIntervalUnit(TimeUnit acquireLockIntervalUnit)
protected void doStop() throws Exception
ServiceSupportServiceSupport.doStop() method when
the service is being stopped. This method will also be invoked
if the service is still in uninitialized state (eg has not
been started). The method is always called to allow the service
to do custom logic when the service is being stopped, such as when
CamelContext is shutting down.doStop in class AbstractCamelClusterService<FileLockClusterView>ExceptionServiceSupport.doStart()Apache Camel