Class RetryStoreServiceImpl
- java.lang.Object
-
- com.adaptris.core.ServiceImp
-
- com.adaptris.core.http.jetty.retry.RetryStoreServiceImpl
-
- All Implemented Interfaces:
AdaptrisComponent
,ComponentLifecycle
,ComponentLifecycleExtension
,MessageEventGenerator
,Service
,StateManagedComponent
- Direct Known Subclasses:
RetryStoreDeleteService
,RetryStoreListService
,RetryStoreWriteService
public abstract class RetryStoreServiceImpl extends ServiceImp
- Since:
- 3.11.1
-
-
Field Summary
-
Fields inherited from class com.adaptris.core.ServiceImp
log
-
-
Constructor Summary
Constructors Constructor Description RetryStoreServiceImpl()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method 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>
TwithRetryStore(RetryStore rs)
-
Methods inherited from class com.adaptris.core.ServiceImp
changeState, close, continueOnFailure, createName, createQualifier, getContinueOnFail, getIsTrackingEndpoint, getUniqueId, init, isBranching, isTrackingEndpoint, requestClose, requestInit, requestStart, requestStop, retrieveComponentState, setContinueOnFail, setIsTrackingEndpoint, setUniqueId
-
-
-
-
Method Detail
-
prepare
public void prepare() throws CoreException
Description copied from interface:ComponentLifecycleExtension
Prepare for initialisation.- Throws:
CoreException
-
initService
protected void initService() throws CoreException
- Specified by:
initService
in classServiceImp
- Throws:
CoreException
-
start
public void start() throws CoreException
Description copied from interface:ComponentLifecycle
Starts the component.Once a component is started it should be ready to process messages. In the case of
AdaptrisMessageConsumer
, calling start will begin message delivery.- Specified by:
start
in interfaceComponentLifecycle
- Overrides:
start
in classServiceImp
- Throws:
CoreException
- wrapping any underlyingException
s
-
stop
public void stop()
Description copied from interface:ComponentLifecycle
Stop the componentA stopped component is not expected to be ready to process messages. In the case of
AdaptrisMessageConsumer
, calling stop will pause message delivery. Throwing aRuntimeException
may cause unintended consequences- Specified by:
stop
in interfaceComponentLifecycle
- Overrides:
stop
in classServiceImp
-
closeService
protected void closeService()
- Specified by:
closeService
in classServiceImp
-
withRetryStore
public <T extends RetryStoreServiceImpl> T withRetryStore(RetryStore rs)
-
getRetryStore
@NonNull public @NonNull RetryStore getRetryStore()
Where messages are stored for retries.
-
setRetryStore
public void setRetryStore(@NonNull @NonNull RetryStore retryStore)
Where messages are stored for retries.
-
-