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

Class AnalyticsMediationFlowObserver

java.lang.Object

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

All Implemented Interfaces:

MessageFlowObserver, TenantInformation

public class AnalyticsMediationFlowObserver
extends Object
implements MessageFlowObserver, TenantInformation

Constructor Summary

Constructors

Constructor and Description
AnalyticsMediationFlowObserver()

Method Summary

Modifier and Type	Method and Description
void	destroy() Clean up this observer and prepare for shutdown
int	getTenantId() Get the tenant id for the observer
void	setTenantId(int i) Set the tenantId for the observer
void	updateStatistics(org.apache.synapse.aspects.flow.statistics.publishing.PublishingFlow flow) Receive a statistics update from the statistics store/provider.

Methods inherited from class java.lang.Object

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

Constructor Detail

AnalyticsMediationFlowObserver

public AnalyticsMediationFlowObserver()

Method Detail

destroy

public void destroy()

Description copied from interface: MessageFlowObserver

Clean up this observer and prepare for shutdown

Specified by:

destroy in interface MessageFlowObserver

updateStatistics

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

Description copied from interface: MessageFlowObserver

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.

Specified by:

updateStatistics in interface MessageFlowObserver

Parameters:

flow - Current latest update containing resource specific data, category specific data, cumulative data and error logs

getTenantId

public int getTenantId()

Description copied from interface: TenantInformation

Get the tenant id for the observer

Specified by:

getTenantId in interface TenantInformation

Returns:

tenantId

setTenantId

public void setTenantId(int i)

Description copied from interface: TenantInformation

Set the tenantId for the observer

Specified by:

setTenantId in interface TenantInformation

Parameters:

i - tenantId of the observer