public class CloseEventCollector extends RuntimeStatisticCollector
eventExpireTime
Constructor and Description |
---|
CloseEventCollector() |
Modifier and Type | Method and Description |
---|---|
static void |
closeEntryEvent(MessageContext messageContext,
String componentName,
ComponentType componentType,
Integer currentIndex,
boolean isContentAltering)
Enqueue statistics event to the event queue.
|
static void |
closeFlowForcefully(MessageContext messageContext,
boolean error)
Enqueue statistics event to the event queue.
|
static void |
tryEndFlow(MessageContext messageContext,
String componentName,
ComponentType componentType,
Integer currentIndex,
boolean isContentAltering)
Enqueue statistics events to the event queue to close and try to finish the flow.
|
addEvent, addEventAndCloseFlow, addEventAndDecrementCallbackCount, addEventAndDecrementCount, addEventAndIncrementCallbackCount, addEventAndIncrementCount, init, isCollectingAllStatistics, isCollectingPayloads, isCollectingProperties, isStatisticsEnabled, setCollectingAllStatistics, setStatisticsTraceId, shouldReportStatistic
public static void closeEntryEvent(MessageContext messageContext, String componentName, ComponentType componentType, Integer currentIndex, boolean isContentAltering)
messageContext
- synapse message context.componentName
- name of the component reporting statistics.componentType
- component type of the reporting component.currentIndex
- component's level in this message flow.isContentAltering
- true if content is alteredpublic static void closeFlowForcefully(MessageContext messageContext, boolean error)
messageContext
- synapse message context.public static void tryEndFlow(MessageContext messageContext, String componentName, ComponentType componentType, Integer currentIndex, boolean isContentAltering)
messageContext
- synapse message context.componentName
- name of the component reporting statistics.componentType
- component type of the reporting component.currentIndex
- component's level in this message flow.isContentAltering
- true if content is alteredCopyright © 2005–2017 Apache Software Foundation. All rights reserved.