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
All Methods Instance Methods Concrete Methods 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)
-
-
-
Field Detail
-
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
-
-
Method Detail
-
onEvent
public void onEvent(FlowableEvent flowableEvent)
- Specified by:
onEvent
in interfaceFlowableEventListener
-
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 interfaceFlowableEventListener
-
isFireOnTransactionLifecycleEvent
public boolean isFireOnTransactionLifecycleEvent()
- Specified by:
isFireOnTransactionLifecycleEvent
in interfaceFlowableEventListener
-
getOnTransaction
public String getOnTransaction()
- Specified by:
getOnTransaction
in interfaceFlowableEventListener
-
getTypes
public Collection<? extends FlowableEventType> getTypes()
- Specified by:
getTypes
in interfaceFlowableEventListener
-
-