Package org.wso2.carbon.das.messageflow.data.publisher.observer

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

    Modifier and Type
    Method
    Description
    void
    destroy()
    Clean up this observer and prepare for shutdown
    void
    updateStatistics(org.apache.synapse.aspects.flow.statistics.publishing.PublishingFlow snapshot)
    Receive a statistics update from the statistics store/provider.

  • Method Details

    • 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