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 and Description
protected static class	WorkflowInterceptorImpl.WorkflowInterceptorException

Field Summary

Fields

Modifier and Type	Field and Description
protected org.slf4j.Logger	log

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	WorkflowInterceptorImpl()

Method Summary

Modifier and Type	Method and Description
void	changeState(ComponentState s) Updates the state for the component ComponentState.
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 recorde ComponentState.
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.WorkflowInterceptor

processingStart, workflowEnd, workflowStart

Methods inherited from interface com.adaptris.core.ComponentLifecycle

close, init, start, stop

Field Detail

log

protected transient org.slf4j.Logger log

Constructor Detail

WorkflowInterceptorImpl

protected WorkflowInterceptorImpl()

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 interface WorkflowInterceptor

Parameters:

c - the channel

registerParentWorkflow

public void registerParentWorkflow(Workflow w)

Register the parent workflow for this WorkflowInterceptor.

Specified by:

registerParentWorkflow in interface WorkflowInterceptor

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 interface AdaptrisComponent

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 interface StateManagedComponent

requestInit

public void requestInit()
                 throws CoreException

Description copied from interface: StateManagedComponent

Request this component is init'd.

Specified by:

requestInit in interface StateManagedComponent

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 interface StateManagedComponent

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 interface StateManagedComponent

See Also:

StateManagedComponent.requestStop()

requestClose

public void requestClose()

Description copied from interface: StateManagedComponent

Request this component is closed.

Specified by:

requestClose in interface StateManagedComponent

See Also:

StateManagedComponent.requestClose()

retrieveComponentState

public ComponentState retrieveComponentState()

Description copied from interface: StateManagedComponent

Returns the last recorde ComponentState.

Specified by:

retrieveComponentState in interface StateManagedComponent

Returns:

the current ComponentState

prepare

public void prepare()
             throws CoreException

Description copied from interface: ComponentLifecycleExtension

Prepare for initialisation.

Specified by:

prepare in interface ComponentLifecycleExtension

Throws:

CoreException

wasSuccessful

protected static boolean wasSuccessful(AdaptrisMessage... msgs)