Package com.adaptris.core.interceptor
Class WorkflowInterceptorImpl
- java.lang.Object
-
- com.adaptris.core.interceptor.WorkflowInterceptorImpl
-
- All Implemented Interfaces:
AdaptrisComponent
,ComponentLifecycle
,ComponentLifecycleExtension
,StateManagedComponent
,WorkflowInterceptor
- Direct Known Subclasses:
InFlightWorkflowInterceptor
,JettyNoBacklogInterceptor
,JettyWorkflowInterceptorImpl
,LoggingContextWorkflowInterceptor
,MetricsInterceptorImpl
,NotifyingInterceptor
,ThrottlingInterceptor
public abstract class WorkflowInterceptorImpl extends java.lang.Object implements WorkflowInterceptor, StateManagedComponent
Abstract WorkflowInterceptor implementation.
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description protected static class
WorkflowInterceptorImpl.WorkflowInterceptorException
-
Field Summary
Fields Modifier and Type Field Description protected org.slf4j.Logger
log
-
Constructor Summary
Constructors Modifier Constructor Description protected
WorkflowInterceptorImpl()
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description void
changeState(ComponentState s)
Updates the state for the componentComponentState
.java.lang.String
getUniqueId()
Returns the configured unique ID for this object.protected Channel
parentChannel()
protected Workflow
parentWorkflow()
void
prepare()
Prepare for initialisation.void
registerParentChannel(Channel c)
Register the parent channel for this WorkflowInterceptor.void
registerParentWorkflow(Workflow w)
Register the parent workflow for this WorkflowInterceptor.void
requestClose()
Request this component is closed.void
requestInit()
Request this component is init'd.void
requestStart()
Request this component is started.void
requestStop()
Request this component is stopped.ComponentState
retrieveComponentState()
Returns the last recordeComponentState
.void
setUniqueId(java.lang.String uniqueId)
protected static boolean
wasSuccessful(AdaptrisMessage... msgs)
-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
-
Methods inherited from interface com.adaptris.core.ComponentLifecycle
close, init, start, stop
-
Methods inherited from interface com.adaptris.core.WorkflowInterceptor
processingStart, workflowEnd, workflowStart
-
-
-
-
Method Detail
-
setUniqueId
public void setUniqueId(java.lang.String uniqueId)
-
registerParentChannel
public void registerParentChannel(Channel c)
Register the parent channel for this WorkflowInterceptor.- Specified by:
registerParentChannel
in interfaceWorkflowInterceptor
- Parameters:
c
- the channel
-
registerParentWorkflow
public void registerParentWorkflow(Workflow w)
Register the parent workflow for this WorkflowInterceptor.- Specified by:
registerParentWorkflow
in interfaceWorkflowInterceptor
- Parameters:
w
- the workflow.
-
parentChannel
protected Channel parentChannel()
-
parentWorkflow
protected Workflow parentWorkflow()
-
getUniqueId
public java.lang.String getUniqueId()
Returns the configured unique ID for this object.
- Specified by:
getUniqueId
in interfaceAdaptrisComponent
- Returns:
- the configured unique ID for this object
-
changeState
public void changeState(ComponentState s)
Description copied from interface:StateManagedComponent
Updates the state for the component
ComponentState
.- Specified by:
changeState
in interfaceStateManagedComponent
-
requestInit
public void requestInit() throws CoreException
Description copied from interface:StateManagedComponent
Request this component is init'd.
- Specified by:
requestInit
in interfaceStateManagedComponent
- Throws:
CoreException
- wrapping any underlying Exceptions- See Also:
StateManagedComponent.requestInit()
-
requestStart
public void requestStart() throws CoreException
Description copied from interface:StateManagedComponent
Request this component is started.
- Specified by:
requestStart
in interfaceStateManagedComponent
- Throws:
CoreException
- wrapping any underlying Exceptions- See Also:
StateManagedComponent.requestStart()
-
requestStop
public void requestStop()
Description copied from interface:StateManagedComponent
Request this component is stopped.
- Specified by:
requestStop
in interfaceStateManagedComponent
- See Also:
StateManagedComponent.requestStop()
-
requestClose
public void requestClose()
Description copied from interface:StateManagedComponent
Request this component is closed.
- Specified by:
requestClose
in interfaceStateManagedComponent
- See Also:
StateManagedComponent.requestClose()
-
retrieveComponentState
public ComponentState retrieveComponentState()
Description copied from interface:StateManagedComponent
Returns the last recorde
ComponentState
.- Specified by:
retrieveComponentState
in interfaceStateManagedComponent
- Returns:
- the current
ComponentState
-
prepare
public void prepare() throws CoreException
Description copied from interface:ComponentLifecycleExtension
Prepare for initialisation.- Specified by:
prepare
in interfaceComponentLifecycleExtension
- Throws:
CoreException
-
wasSuccessful
protected static boolean wasSuccessful(AdaptrisMessage... msgs)
-
-