org.wso2.ei.analytics.elk.observer

Class ElasticMediationFlowObserver

java.lang.Object

org.wso2.ei.analytics.elk.observer.ElasticMediationFlowObserver

All Implemented Interfaces:

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

public class ElasticMediationFlowObserver
extends Object
implements org.wso2.carbon.das.messageflow.data.publisher.observer.MessageFlowObserver

This class is instantiated by MediationStatisticsComponent. Gets stored in MessageFlowObserverStore and updateStatistics() is notified by the MessageFlowReporterThread.

Constructor Summary

Constructors

Constructor and Description
ElasticMediationFlowObserver() Instantiates the TransportClient as this class is instantiated

Method Summary

Modifier and Type	Method and Description
void	destroy() TransportClient gets closed
void	updateStatistics(org.apache.synapse.aspects.flow.statistics.publishing.PublishingFlow publishingFlow) Method is called when this observer is notified.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ElasticMediationFlowObserver

public ElasticMediationFlowObserver()

Instantiates the TransportClient as this class is instantiated

Method Detail

destroy

public void destroy()

TransportClient gets closed

Specified by:

destroy in interface org.wso2.carbon.das.messageflow.data.publisher.observer.MessageFlowObserver

updateStatistics

public void updateStatistics(org.apache.synapse.aspects.flow.statistics.publishing.PublishingFlow publishingFlow)

Method is called when this observer is notified. Invokes the process method considering about the queue size.

Specified by:

updateStatistics in interface org.wso2.carbon.das.messageflow.data.publisher.observer.MessageFlowObserver

Parameters:

publishingFlow - PublishingFlow object is passed when notified.