Package com.axelor.workflow.monitor

Class WorkflowEngineMonitor

java.lang.Object

com.axelor.workflow.monitor.WorkflowEngineMonitor

All Implemented Interfaces:

WorkflowEngineMXBean

@Singleton
public class WorkflowEngineMonitor
extends Object
implements WorkflowEngineMXBean

Lock-free workflow metrics published as a read-only platform MXBean.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
final class	WorkflowEngineMonitor.ExecutionObservation
static final class	WorkflowEngineMonitor.JoinObservation
static final class	WorkflowEngineMonitor.MessageDeliveryObservation
final class	WorkflowEngineMonitor.NodeObservation
final class	WorkflowEngineMonitor.PollObservation

Constructor Summary

Constructors

Constructor	Description
WorkflowEngineMonitor()

Method Summary

Modifier and Type	Method	Description
WorkflowEngineMonitor.ExecutionObservation	executionStarted(String workflow, boolean resume)
int	getActiveExecutionSegments()
int	getActiveSchedulerWorkers()
double	getAverageExecutionDurationMillis()
double	getAveragePollDurationMillis()
long	getExecutionSegmentsFailed()
long	getExecutionSegmentsSkipped()
long	getExecutionSegmentsStarted()
long	getExecutionSegmentsSucceeded()
long	getExecutionSegmentsWaiting()
int	getInFlightTenants()
long	getJoinClaimsReaped()
long	getLastExecutionDurationMillis()
Date	getLastPollCompletedAt()
long	getLastPollDurationMillis()
Date	getLastPollStartedAt()
long	getMaxExecutionDurationMillis()
long	getMaxPollDurationMillis()
long	getMessagesDelivered()
long	getMessagesExpired()
long	getMessagesFailed()
long	getMessagesQueued()
String	getNodeId()
long	getNodesExecuted()
long	getNodesFailed()
long	getOverlappingPollsSkipped()
long	getPollsFailed()
long	getPollsRejected()
long	getPollsStarted()
long	getPollsSucceeded()
int	getQueuedSchedulerPolls()
long	getResumesStarted()
int	getSchedulerBatchSize()
int	getSchedulerIntervalSeconds()
int	getSchedulerWorkerPoolSize()
long	getStaleClaimsReaped()	Every claim handed back, whatever kind — the three below are what it is made of.
long	getStateClaimsReaped()
long	getTaskClaimsReaped()
long	getUnexpectedExecutionFailures()
void	inFlightTenants(int count)
boolean	isSchedulerRunning()
void	joinClaimsReaped(int count)
WorkflowEngineMonitor.JoinObservation	joinStarted(String splitNode, String joinNode)
void	messageDelivered()
WorkflowEngineMonitor.MessageDeliveryObservation	messageDeliveryStarted(String message, String expectation, int attempt)
void	messageExpired()
void	messageFailed()
void	messageQueued()
WorkflowEngineMonitor.NodeObservation	nodeStarted(String workflow, String node, String nodeType)
void	pollQueued(int inFlightCount)
void	pollRejected(int inFlightCount)
void	pollSkipped()
WorkflowEngineMonitor.PollObservation	pollStarted()
void	register(String nodeId)
void	schedulerConfigured(String nodeId, int intervalSeconds, int poolSize, int batchSize)
void	schedulerStarted()
void	schedulerStopped()
void	staleClaimsReaped(int stateClaims, int taskClaims)
void	unregister()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

WorkflowEngineMonitor

public WorkflowEngineMonitor()

Method Details

register

public void register(String nodeId)

unregister

public void unregister()

schedulerConfigured

public void schedulerConfigured(String nodeId,
 int intervalSeconds,
 int poolSize,
 int batchSize)

schedulerStarted

public void schedulerStarted()

schedulerStopped

public void schedulerStopped()

pollQueued

public void pollQueued(int inFlightCount)

pollRejected

public void pollRejected(int inFlightCount)

pollStarted

public WorkflowEngineMonitor.PollObservation pollStarted()

pollSkipped

public void pollSkipped()

inFlightTenants

public void inFlightTenants(int count)

executionStarted

public WorkflowEngineMonitor.ExecutionObservation executionStarted(String workflow,
 boolean resume)

nodeStarted

public WorkflowEngineMonitor.NodeObservation nodeStarted(String workflow,
 String node,
 String nodeType)

messageDeliveryStarted

public WorkflowEngineMonitor.MessageDeliveryObservation messageDeliveryStarted(String message,
 String expectation,
 int attempt)

joinStarted

public WorkflowEngineMonitor.JoinObservation joinStarted(String splitNode,
 String joinNode)

messageQueued

public void messageQueued()

messageDelivered

public void messageDelivered()

messageExpired

public void messageExpired()

messageFailed

public void messageFailed()

staleClaimsReaped

public void staleClaimsReaped(int stateClaims,
 int taskClaims)

joinClaimsReaped

public void joinClaimsReaped(int count)

getNodeId

public String getNodeId()

Specified by:

getNodeId in interface WorkflowEngineMXBean

isSchedulerRunning

public boolean isSchedulerRunning()

Specified by:

isSchedulerRunning in interface WorkflowEngineMXBean

getSchedulerIntervalSeconds

public int getSchedulerIntervalSeconds()

Specified by:

getSchedulerIntervalSeconds in interface WorkflowEngineMXBean

getSchedulerWorkerPoolSize

public int getSchedulerWorkerPoolSize()

Specified by:

getSchedulerWorkerPoolSize in interface WorkflowEngineMXBean

getSchedulerBatchSize

public int getSchedulerBatchSize()

Specified by:

getSchedulerBatchSize in interface WorkflowEngineMXBean

getActiveSchedulerWorkers

public int getActiveSchedulerWorkers()

Specified by:

getActiveSchedulerWorkers in interface WorkflowEngineMXBean

getQueuedSchedulerPolls

public int getQueuedSchedulerPolls()

Specified by:

getQueuedSchedulerPolls in interface WorkflowEngineMXBean

getInFlightTenants

public int getInFlightTenants()

Specified by:

getInFlightTenants in interface WorkflowEngineMXBean

getPollsStarted

public long getPollsStarted()

Specified by:

getPollsStarted in interface WorkflowEngineMXBean

getPollsSucceeded

public long getPollsSucceeded()

Specified by:

getPollsSucceeded in interface WorkflowEngineMXBean

getPollsFailed

public long getPollsFailed()

Specified by:

getPollsFailed in interface WorkflowEngineMXBean

getPollsRejected

public long getPollsRejected()

Specified by:

getPollsRejected in interface WorkflowEngineMXBean

getOverlappingPollsSkipped

public long getOverlappingPollsSkipped()

Specified by:

getOverlappingPollsSkipped in interface WorkflowEngineMXBean

getLastPollStartedAt

public Date getLastPollStartedAt()

Specified by:

getLastPollStartedAt in interface WorkflowEngineMXBean

getLastPollCompletedAt

public Date getLastPollCompletedAt()

Specified by:

getLastPollCompletedAt in interface WorkflowEngineMXBean

getLastPollDurationMillis

public long getLastPollDurationMillis()

Specified by:

getLastPollDurationMillis in interface WorkflowEngineMXBean

getAveragePollDurationMillis

public double getAveragePollDurationMillis()

Specified by:

getAveragePollDurationMillis in interface WorkflowEngineMXBean

getMaxPollDurationMillis

public long getMaxPollDurationMillis()

Specified by:

getMaxPollDurationMillis in interface WorkflowEngineMXBean

getExecutionSegmentsStarted

public long getExecutionSegmentsStarted()

Specified by:

getExecutionSegmentsStarted in interface WorkflowEngineMXBean

getResumesStarted

public long getResumesStarted()

Specified by:

getResumesStarted in interface WorkflowEngineMXBean

getActiveExecutionSegments

public int getActiveExecutionSegments()

Specified by:

getActiveExecutionSegments in interface WorkflowEngineMXBean

getExecutionSegmentsSucceeded

public long getExecutionSegmentsSucceeded()

Specified by:

getExecutionSegmentsSucceeded in interface WorkflowEngineMXBean

getExecutionSegmentsWaiting

public long getExecutionSegmentsWaiting()

Specified by:

getExecutionSegmentsWaiting in interface WorkflowEngineMXBean

getExecutionSegmentsSkipped

public long getExecutionSegmentsSkipped()

Specified by:

getExecutionSegmentsSkipped in interface WorkflowEngineMXBean

getExecutionSegmentsFailed

public long getExecutionSegmentsFailed()

Specified by:

getExecutionSegmentsFailed in interface WorkflowEngineMXBean

getUnexpectedExecutionFailures

public long getUnexpectedExecutionFailures()

Specified by:

getUnexpectedExecutionFailures in interface WorkflowEngineMXBean

getLastExecutionDurationMillis

public long getLastExecutionDurationMillis()

Specified by:

getLastExecutionDurationMillis in interface WorkflowEngineMXBean

getAverageExecutionDurationMillis

public double getAverageExecutionDurationMillis()

Specified by:

getAverageExecutionDurationMillis in interface WorkflowEngineMXBean

getMaxExecutionDurationMillis

public long getMaxExecutionDurationMillis()

Specified by:

getMaxExecutionDurationMillis in interface WorkflowEngineMXBean

getNodesExecuted

public long getNodesExecuted()

Specified by:

getNodesExecuted in interface WorkflowEngineMXBean

getNodesFailed

public long getNodesFailed()

Specified by:

getNodesFailed in interface WorkflowEngineMXBean

getMessagesQueued

public long getMessagesQueued()

Specified by:

getMessagesQueued in interface WorkflowEngineMXBean

getMessagesDelivered

public long getMessagesDelivered()

Specified by:

getMessagesDelivered in interface WorkflowEngineMXBean

getMessagesExpired

public long getMessagesExpired()

Specified by:

getMessagesExpired in interface WorkflowEngineMXBean

getMessagesFailed

public long getMessagesFailed()

Specified by:

getMessagesFailed in interface WorkflowEngineMXBean

getStaleClaimsReaped

public long getStaleClaimsReaped()

Description copied from interface: WorkflowEngineMXBean

Every claim handed back, whatever kind — the three below are what it is made of.

Specified by:

getStaleClaimsReaped in interface WorkflowEngineMXBean

getStateClaimsReaped

public long getStateClaimsReaped()

Specified by:

getStateClaimsReaped in interface WorkflowEngineMXBean

getTaskClaimsReaped

public long getTaskClaimsReaped()

Specified by:

getTaskClaimsReaped in interface WorkflowEngineMXBean

getJoinClaimsReaped

public long getJoinClaimsReaped()

Specified by:

getJoinClaimsReaped in interface WorkflowEngineMXBean