public class MessageInFlight extends ChildRuntimeInfoComponentImpl implements MessageInFlightMBean
log
Modifier | Constructor and Description |
---|---|
protected |
MessageInFlight(WorkflowManager owner,
InFlightWorkflowInterceptor interceptor) |
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() |
createObjectName, getParentId, getParentObjectName, registerMBean, unregisterMBean
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getParentId, getParentObjectName
createObjectName, registerMBean, unregisterMBean
protected MessageInFlight(WorkflowManager owner, InFlightWorkflowInterceptor interceptor)
protected java.lang.String getType()
getType
in class ChildRuntimeInfoComponentImpl
protected java.lang.String uniqueId()
uniqueId
in class ChildRuntimeInfoComponentImpl
public boolean messagesInFlight()
MessageInFlightMBean
messagesInFlight
in interface MessageInFlightMBean
public int messagesPendingCount()
MessageInFlightMBean
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.
messagesPendingCount
in interface MessageInFlightMBean
JettyNoBacklogInterceptor
public int messagesInFlightCount()
MessageInFlightMBean
Other than PoolingWorkflow
, this will generally return 1 or 0. PoolingWorkflow
will at most return
PoolingWorkflow.getPoolSize()
. It is included for completeness.
messagesInFlightCount
in interface MessageInFlightMBean
public ParentRuntimeInfoComponent getParentRuntimeInfoComponent()
getParentRuntimeInfoComponent
in interface ChildRuntimeInfoComponent