com.adaptris.core.interceptor

Class MessageInFlight

java.lang.Object

com.adaptris.core.runtime.ChildRuntimeInfoComponentImpl

com.adaptris.core.interceptor.MessageInFlight

All Implemented Interfaces:

MessageInFlightMBean, BaseComponentMBean, ChildRuntimeInfoComponent, ChildRuntimeInfoComponentMBean, RuntimeInfoComponent

public class MessageInFlight
extends ChildRuntimeInfoComponentImpl
implements MessageInFlightMBean

Field Summary

Fields inherited from class com.adaptris.core.runtime.ChildRuntimeInfoComponentImpl

log

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	MessageInFlight(WorkflowManager owner, InFlightWorkflowInterceptor interceptor)

Method Summary

Modifier and Type	Method and Description
ParentRuntimeInfoComponent	getParentRuntimeInfoComponent()
protected java.lang.String	getType()
boolean	messagesInFlight() Whether or not there are any messages in flight for the workflow.
int	messagesInFlightCount() Return the count of messages that are currently in flight.
int	messagesPendingCount() Return the count of messages that are currently queued.
protected java.lang.String	uniqueId()

Methods inherited from class com.adaptris.core.runtime.ChildRuntimeInfoComponentImpl

createObjectName, getParentId, getParentObjectName, registerMBean, unregisterMBean

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.runtime.ChildRuntimeInfoComponentMBean

getParentId, getParentObjectName

Methods inherited from interface com.adaptris.core.runtime.BaseComponentMBean

createObjectName, registerMBean, unregisterMBean

Constructor Detail

MessageInFlight

protected MessageInFlight(WorkflowManager owner,
                          InFlightWorkflowInterceptor interceptor)

Method Detail

getType

protected java.lang.String getType()

Specified by:

getType in class ChildRuntimeInfoComponentImpl

uniqueId

protected java.lang.String uniqueId()

Specified by:

uniqueId in class ChildRuntimeInfoComponentImpl

messagesInFlight

public boolean messagesInFlight()

Description copied from interface: MessageInFlightMBean

Whether or not there are any messages in flight for the workflow.

Specified by:

messagesInFlight in interface MessageInFlightMBean

Returns:

true if there are messages in flight

messagesPendingCount

public int messagesPendingCount()

Description copied from interface: MessageInFlightMBean

Return the count of messages that are currently queued.

This only makes sense for PoolingWorkflow as other workflows are single threaded; so will most likely return 0. In the context of PoolingWorkflow, this is the number of messages that have been submitted to the workflow, but have not yet been processed.

Specified by:

messagesPendingCount in interface MessageInFlightMBean

Returns:

the number of messages that have been submitted for processing, but have not entered the workflow proper.

See Also:

JettyNoBacklogInterceptor

messagesInFlightCount

public int messagesInFlightCount()

Description copied from interface: MessageInFlightMBean

Return the count of messages that are currently in flight.

Other than PoolingWorkflow, this will generally return 1 or 0. PoolingWorkflow will at most return WorkflowWithObjectPool.getPoolSize(). It is included for completeness.

Specified by:

messagesInFlightCount in interface MessageInFlightMBean

Returns:

the number of messages in flight.

getParentRuntimeInfoComponent

public ParentRuntimeInfoComponent getParentRuntimeInfoComponent()

Specified by:

getParentRuntimeInfoComponent in interface ChildRuntimeInfoComponent