public abstract class RetryStoreServiceImpl extends ServiceImp
log
Constructor and Description |
---|
RetryStoreServiceImpl() |
Modifier and Type | Method and Description |
---|---|
protected void |
closeService() |
@NonNull RetryStore |
getRetryStore()
Where messages are stored for retries.
|
protected void |
initService() |
void |
prepare()
Prepare for initialisation.
|
void |
setRetryStore(@NonNull RetryStore retryStore)
Where messages are stored for retries.
|
void |
start()
Starts the component.
|
void |
stop()
Stop the component
|
<T extends RetryStoreServiceImpl> |
withRetryStore(RetryStore rs) |
changeState, close, continueOnFailure, createName, createQualifier, getContinueOnFail, getIsTrackingEndpoint, getUniqueId, init, isBranching, isTrackingEndpoint, requestClose, requestInit, requestStart, requestStop, retrieveComponentState, setContinueOnFail, setIsTrackingEndpoint, setUniqueId
public void prepare() throws CoreException
ComponentLifecycleExtension
CoreException
protected void initService() throws CoreException
initService
in class ServiceImp
CoreException
public void start() throws CoreException
ComponentLifecycle
Once a component is started it should be ready to process messages. In the case of AdaptrisMessageConsumer
, calling start
will begin message delivery.
start
in interface ComponentLifecycle
start
in class ServiceImp
CoreException
- wrapping any underlying Exception
spublic void stop()
ComponentLifecycle
A stopped component is not expected to be ready to process messages. In the case of AdaptrisMessageConsumer
, calling stop
will pause message delivery. Throwing a RuntimeException
may cause unintended consequences
stop
in interface ComponentLifecycle
stop
in class ServiceImp
protected void closeService()
closeService
in class ServiceImp
public <T extends RetryStoreServiceImpl> T withRetryStore(RetryStore rs)
@NonNull public @NonNull RetryStore getRetryStore()
public void setRetryStore(@NonNull @NonNull RetryStore retryStore)