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 Description AnalyticsMediationFlowObserver()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
destroy()
Clean up this observer and prepare for shutdownint
getTenantId()
Get the tenant id for the observervoid
setTenantId(int i)
Set the tenantId for the observervoid
updateStatistics(org.apache.synapse.aspects.flow.statistics.publishing.PublishingFlow flow)
Receive a statistics update from the statistics store/provider.
-
-
-
Method Detail
-
destroy
public void destroy()
Description copied from interface:MessageFlowObserver
Clean up this observer and prepare for shutdown- Specified by:
destroy
in interfaceMessageFlowObserver
-
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 interfaceMessageFlowObserver
- 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 interfaceTenantInformation
- Returns:
- tenantId
-
setTenantId
public void setTenantId(int i)
Description copied from interface:TenantInformation
Set the tenantId for the observer- Specified by:
setTenantId
in interfaceTenantInformation
- Parameters:
i
- tenantId of the observer
-
-