Class CallbackStatisticCollector
- java.lang.Object
-
- org.apache.synapse.aspects.flow.statistics.collectors.RuntimeStatisticCollector
-
- org.apache.synapse.aspects.flow.statistics.collectors.CallbackStatisticCollector
-
public class CallbackStatisticCollector extends RuntimeStatisticCollector
-
-
Field Summary
-
Fields inherited from class org.apache.synapse.aspects.flow.statistics.collectors.RuntimeStatisticCollector
eventExpireTime
-
-
Constructor Summary
Constructors Constructor Description CallbackStatisticCollector()
-
Method Summary
All Methods Static Methods Concrete Methods Modifier and Type Method Description static void
addCallback(MessageContext messageContext, String callbackId)
Enqueue CallbackSentEvent event to the event queue.static void
callbackCompletionEvent(MessageContext oldMessageContext, String callbackId)
Enqueue CallbackCompletionEvent event to the event queue.static void
reportCallbackHandlingCompletion(MessageContext synapseOutMsgCtx, String callbackId)
Enqueue CallbackHandledEvent event to the event queue.static void
updateParentsForCallback(MessageContext oldMessageContext, String callbackId)
Enqueue CallbackReceivedEvent event 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
-
addCallback
public static void addCallback(MessageContext messageContext, String callbackId)
Enqueue CallbackSentEvent event to the event queue. This corresponds to the registering of callback for the message flow by the SynapseCallbackReceiver.- Parameters:
messageContext
- Current MessageContext of the flow.callbackId
- Callback Id.
-
callbackCompletionEvent
public static void callbackCompletionEvent(MessageContext oldMessageContext, String callbackId)
Enqueue CallbackCompletionEvent event to the event queue. This event inform that callback handling finished or callback is removed by the TimeoutHandler.- Parameters:
oldMessageContext
- Current MessageContext of the flow.callbackId
- Callback Id.
-
updateParentsForCallback
public static void updateParentsForCallback(MessageContext oldMessageContext, String callbackId)
Enqueue CallbackReceivedEvent event to the event queue. This informs that callback has received its response.- Parameters:
oldMessageContext
- Current MessageContext of the flow.callbackId
- Callback Id.
-
reportCallbackHandlingCompletion
public static void reportCallbackHandlingCompletion(MessageContext synapseOutMsgCtx, String callbackId)
Enqueue CallbackHandledEvent event to the event queue. This informs that callback handling is finished after receiving the callback.- Parameters:
synapseOutMsgCtx
- Old MessageContext of the flow.callbackId
- Callback Id.
-
-