Class MessageDataStore
- java.lang.Object
-
- org.apache.synapse.aspects.flow.statistics.store.MessageDataStore
-
public class MessageDataStore extends Object
MessageDataCollector contains the non-blocking queue and utility methods to store and retrieve elements from the queue.
-
-
Constructor Summary
Constructors Constructor Description MessageDataStore(SynapseConfiguration synCfg)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description StatisticsReportingEventHolder
dequeue()
Removes and return StatisticReportingLog from the queuevoid
enqueue(StatisticsReportingEventHolder statisticsReportingEventHolder)
Add StatisticsReportingEventHolder instance to the queue
-
-
-
Constructor Detail
-
MessageDataStore
public MessageDataStore(SynapseConfiguration synCfg)
-
-
Method Detail
-
enqueue
public void enqueue(StatisticsReportingEventHolder statisticsReportingEventHolder)
Add StatisticsReportingEventHolder instance to the queue- Parameters:
statisticsReportingEventHolder
- StatisticReportingLog to be stored in the queue
-
dequeue
public StatisticsReportingEventHolder dequeue() throws Exception
Removes and return StatisticReportingLog from the queue- Returns:
- StatisticReportingLog instance
- Throws:
Exception
-
-