Package com.flowable.core.micrometer.impl.job

Class JobFailureMetricsEventListener

java.lang.Object

com.flowable.core.micrometer.impl.job.JobFailureMetricsEventListener

All Implemented Interfaces:

FlowableEventListener

public class JobFailureMetricsEventListener
extends Object
implements FlowableEventListener

Field Summary

Fields

Modifier and Type	Field	Description
protected io.micrometer.core.instrument.Counter	asyncJobFailedCounter
protected io.micrometer.core.instrument.Counter	asyncJobMovedToDeadletterCounter
protected io.micrometer.core.instrument.Counter	asyncJobRejectedCounter
protected io.micrometer.core.instrument.Counter	externalJobFailedCounter
protected io.micrometer.core.instrument.Counter	externalJobMovedToDeadletterCounter
protected io.micrometer.core.instrument.Counter	externalJobRejectedCounter
protected io.micrometer.core.instrument.Counter	historyJobFailedCounter
protected io.micrometer.core.instrument.Counter	historyJobMovedToDeadletterCounter
protected io.micrometer.core.instrument.Counter	historyJobRejectedCounter
protected io.micrometer.core.instrument.Counter	timerJobFailedCounter
protected io.micrometer.core.instrument.Counter	timerJobMovedToDeadletterCounter
protected io.micrometer.core.instrument.Counter	timerJobRejectedCounter

Constructor Summary

Constructors

Constructor	Description
JobFailureMetricsEventListener(io.micrometer.core.instrument.MeterRegistry registry)

Method Summary

Modifier and Type	Method	Description
String	getOnTransaction()
Collection<? extends FlowableEventType>	getTypes()
protected void	handleJobExecutionFailureEvent(FlowableEvent flowableEvent)
protected void	handleJobMovedToDeadletter(FlowableEvent flowableEvent)
protected void	handleJobRejectedEvent(FlowableEvent flowableEvent)
boolean	isFailOnException()
boolean	isFireOnTransactionLifecycleEvent()
void	onEvent(FlowableEvent flowableEvent)

Methods inherited from class java.lang.Object

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

Field Details

asyncJobFailedCounter

protected io.micrometer.core.instrument.Counter asyncJobFailedCounter

asyncJobRejectedCounter

protected io.micrometer.core.instrument.Counter asyncJobRejectedCounter

asyncJobMovedToDeadletterCounter

protected io.micrometer.core.instrument.Counter asyncJobMovedToDeadletterCounter

timerJobFailedCounter

protected io.micrometer.core.instrument.Counter timerJobFailedCounter

timerJobRejectedCounter

protected io.micrometer.core.instrument.Counter timerJobRejectedCounter

timerJobMovedToDeadletterCounter

protected io.micrometer.core.instrument.Counter timerJobMovedToDeadletterCounter

historyJobFailedCounter

protected io.micrometer.core.instrument.Counter historyJobFailedCounter

historyJobRejectedCounter

protected io.micrometer.core.instrument.Counter historyJobRejectedCounter

historyJobMovedToDeadletterCounter

protected io.micrometer.core.instrument.Counter historyJobMovedToDeadletterCounter

externalJobFailedCounter

protected io.micrometer.core.instrument.Counter externalJobFailedCounter

externalJobRejectedCounter

protected io.micrometer.core.instrument.Counter externalJobRejectedCounter

externalJobMovedToDeadletterCounter

protected io.micrometer.core.instrument.Counter externalJobMovedToDeadletterCounter

Constructor Details

JobFailureMetricsEventListener

public JobFailureMetricsEventListener(io.micrometer.core.instrument.MeterRegistry registry)

Method Details

onEvent

public void onEvent(FlowableEvent flowableEvent)

Specified by:

onEvent in interface FlowableEventListener

handleJobExecutionFailureEvent

protected void handleJobExecutionFailureEvent(FlowableEvent flowableEvent)

handleJobRejectedEvent

protected void handleJobRejectedEvent(FlowableEvent flowableEvent)

handleJobMovedToDeadletter

protected void handleJobMovedToDeadletter(FlowableEvent flowableEvent)

isFailOnException

public boolean isFailOnException()

Specified by:

isFailOnException in interface FlowableEventListener

isFireOnTransactionLifecycleEvent

public boolean isFireOnTransactionLifecycleEvent()

Specified by:

isFireOnTransactionLifecycleEvent in interface FlowableEventListener

getOnTransaction

public String getOnTransaction()

Specified by:

getOnTransaction in interface FlowableEventListener

getTypes

public Collection<? extends FlowableEventType> getTypes()

Specified by:

getTypes in interface FlowableEventListener