Interface MessageFlowObserver
-
- All Known Implementing Classes:
AnalyticsMediationFlowObserver
,JMXMediationFlowObserver
public interface MessageFlowObserver
This interface can be used to register consumers into the MediationStatisticsStore and retrieve statistics updates from the data store.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description void
destroy()
Clean up this observer and prepare for shutdownvoid
updateStatistics(org.apache.synapse.aspects.flow.statistics.publishing.PublishingFlow snapshot)
Receive a statistics update from the statistics store/provider.
-
-
-
Method Detail
-
destroy
void destroy()
Clean up this observer and prepare for shutdown
-
updateStatistics
void updateStatistics(org.apache.synapse.aspects.flow.statistics.publishing.PublishingFlow snapshot)
Receive a statistics update from the statistics store/provider. The cumulative records received from this method will be 'null' for the very first update sent by the data store. This is because for the very first update there are no cumulative data in the store. The implementations of this method should not attempt to modify the provided StatisticsRecord instances. If such modifications are necessary the StatisticsRecord objects should be first copied using the copy constructor. Also implementations of the updateStatistics method should finish quickly. Long running tasks should be executed using separate threads to prevent the notifier thread getting blocked.- Parameters:
snapshot
- Current latest update containing resource specific data, category specific data, cumulative data and error logs
-
-