Package org.wso2.carbon.usage.agent.persist

Class UsageDataPersistenceTask

java.lang.Object

org.wso2.carbon.usage.agent.persist.UsageDataPersistenceTask

All Implemented Interfaces:

Runnable

public class UsageDataPersistenceTask
extends Object
implements Runnable

Constructor Summary

Constructors

Constructor	Description
UsageDataPersistenceTask(Queue<BandwidthUsage> jobs, UsageAgentConfiguration configuration)

Method Summary

Modifier and Type	Method	Description
void	persistUsage(Queue<BandwidthUsage> jobQueue)	this method create a Summarizer object for each tenant and call accumulate() method to accumulate usage statistics
void	run()

Methods inherited from class java.lang.Object

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

Constructor Details

UsageDataPersistenceTask

public UsageDataPersistenceTask(Queue<BandwidthUsage> jobs,
 UsageAgentConfiguration configuration)

Method Details

run

public void run()

Specified by:

run in interface Runnable

persistUsage

public void persistUsage(Queue<BandwidthUsage> jobQueue)
                  throws UsageException

this method create a Summarizer object for each tenant and call accumulate() method to accumulate usage statistics

Parameters:

jobQueue - usage data persistence jobs

Throws:

UsageException