Class OpenEventCollector
- java.lang.Object
-
- org.apache.synapse.aspects.flow.statistics.collectors.RuntimeStatisticCollector
-
- org.apache.synapse.aspects.flow.statistics.collectors.OpenEventCollector
-
public class OpenEventCollector extends RuntimeStatisticCollector
OpenEventCollector receives open statistic events from synapse mediation engine. It Receives Statistics for Proxy Services, Inbound Endpoints, APIs, Sequences, Endpoints, Mediators and Resources.
-
-
Field Summary
-
Fields inherited from class org.apache.synapse.aspects.flow.statistics.collectors.RuntimeStatisticCollector
eventExpireTime
-
-
Constructor Summary
Constructors Constructor Description OpenEventCollector()
-
Method Summary
All Methods Static Methods Concrete Methods Modifier and Type Method Description static void
openContinuationEvents(MessageContext synCtx)
Add event in to the event queue.static Integer
reportChildEntryEvent(MessageContext messageContext, String componentName, ComponentType componentType, AspectConfiguration aspectConfiguration, boolean isContentAltering)
Enqueue StatisticOpenEvent to the event Queue.static Integer
reportEntryEvent(MessageContext messageContext, String componentName, AspectConfiguration aspectConfiguration, ComponentType componentType)
Enqueue StatisticOpenEvent to the event Queue.static Integer
reportFlowAggregateEvent(MessageContext messageContext, String componentName, ComponentType componentType, AspectConfiguration aspectConfiguration, boolean isContentAltering)
Enqueue StatisticOpenEvent to the event Queue.static void
reportFlowAsynchronousEvent(MessageContext messageContext)
Enqueue StatisticOpenEvent for asynchronous invocation.static Integer
reportFlowContinuableEvent(MessageContext messageContext, String componentName, ComponentType componentType, AspectConfiguration aspectConfiguration, boolean isContentAltering)
Enqueue StatisticOpenEvent to the event Queue.static Integer
reportFlowSplittingEvent(MessageContext messageContext, String componentName, ComponentType componentType, AspectConfiguration aspectConfiguration, boolean isContentAltering)
Enqueue StatisticOpenEvent to the event Queue.-
Methods inherited from class org.apache.synapse.aspects.flow.statistics.collectors.RuntimeStatisticCollector
addEvent, addEventAndCloseFlow, addEventAndDecrementCallbackCount, addEventAndDecrementCount, addEventAndIncrementCallbackCount, addEventAndIncrementCount, init, isCollectingAllStatistics, isCollectingPayloads, isCollectingProperties, isMediationFlowStatisticsEnabled, isOpenTelemetryEnabled, isStatisticsEnabled, setCollectingAllStatistics, setStatisticsTraceId, shouldReportStatistic
-
-
-
-
Method Detail
-
reportEntryEvent
public static Integer reportEntryEvent(MessageContext messageContext, String componentName, AspectConfiguration aspectConfiguration, ComponentType componentType)
Enqueue StatisticOpenEvent to the event Queue. This receives open events from Proxy Services, Endpoints, APIs, Inbound Endpoints and Sequences which are considered as entry components for statistics collection. These components can start statistic collection if their individual statistic collection is enabled. If statistics is already enabled, this will enqueue open event to the queue regardless of its individual statistics collection.- Parameters:
messageContext
- synapse message context.componentName
- statistic reporting component name.aspectConfiguration
- aspect configuration of the reporting component.componentType
- component type of the reporting component.- Returns:
- component's level in this message flow.
-
reportChildEntryEvent
public static Integer reportChildEntryEvent(MessageContext messageContext, String componentName, ComponentType componentType, AspectConfiguration aspectConfiguration, boolean isContentAltering)
Enqueue StatisticOpenEvent to the event Queue. This receives open events from Mediators and Resources. These components can't start statistic collection. If statistics is already enabled, it will enqueue open event to the queue regardless of its individual statistics collection. If its disabled it will not enqueue open event to the event queue.- Parameters:
messageContext
- synapse message context.componentName
- statistic reporting component name.componentType
- component type of the reporting component.aspectConfiguration
- aspect configuration of the componentisContentAltering
- component is altering the content- Returns:
- component's level in this message flow.
-
reportFlowContinuableEvent
public static Integer reportFlowContinuableEvent(MessageContext messageContext, String componentName, ComponentType componentType, AspectConfiguration aspectConfiguration, boolean isContentAltering)
Enqueue StatisticOpenEvent to the event Queue. This receives open events from Flow Continuable Mediators. These components can't start statistic collection. If statistics is already enabled, it will enqueue open event to the queue regardless of its individual statistics collection. If its disabled it will not enqueue open event to the event queue.- Parameters:
messageContext
- synapse message context.componentName
- statistic reporting component name.componentType
- component type of the reporting component.aspectConfiguration
- aspect configuration of the componentisContentAltering
- component is altering the content- Returns:
- component's level in this message flow.
-
reportFlowSplittingEvent
public static Integer reportFlowSplittingEvent(MessageContext messageContext, String componentName, ComponentType componentType, AspectConfiguration aspectConfiguration, boolean isContentAltering)
Enqueue StatisticOpenEvent to the event Queue. This receives open events from Flow Splitting Mediators like Clone Mediator and Iterate Mediator. These components can't start statistic collection. If statistics is already enabled, it will enqueue open event to the queue regardless of its individual statistics collection. If its disabled it will not enqueue open event to the event queue.- Parameters:
messageContext
- synapse message context.componentName
- statistic reporting component name.componentType
- component type of the reporting component.aspectConfiguration
- aspect configuration of the componentisContentAltering
- component is altering the content- Returns:
- component's level in this message flow.
-
reportFlowAggregateEvent
public static Integer reportFlowAggregateEvent(MessageContext messageContext, String componentName, ComponentType componentType, AspectConfiguration aspectConfiguration, boolean isContentAltering)
Enqueue StatisticOpenEvent to the event Queue. This receives open events from Flow Aggregate Mediator. These components can't start statistic collection. If statistics is already enabled, it will enqueue open event to the queue regardless of its individual statistics collection. If its disabled it will not enqueue open event to the event queue.- Parameters:
messageContext
- synapse message context.componentName
- statistic reporting component name.componentType
- component type of the component.aspectConfiguration
- aspect configuration of the componentisContentAltering
- component is altering the content- Returns:
- component's level in this message flow.
-
reportFlowAsynchronousEvent
public static void reportFlowAsynchronousEvent(MessageContext messageContext)
Enqueue StatisticOpenEvent for asynchronous invocation.- Parameters:
messageContext
- synapse message context.
-
openContinuationEvents
public static void openContinuationEvents(MessageContext synCtx)
Add event in to the event queue. This event will inform statistic collection to put all the flow continuable mediators before the index specified by current Index to open state.- Parameters:
synCtx
- synapse message context.
-
-