net.sf.infrared.agent.transport
Class BufferedAggregator

java.lang.Object
  net.sf.infrared.agent.transport.BufferedAggregator

All Implemented Interfaces:

Aggregator

public class BufferedAggregator

extends Object

implements Aggregator

Implementation of the aggregator which merges each update with a local statistics instance and flushes the aggregated statistics in response to a flush.

Constructor Summary

BufferedAggregator()

Method Summary

void	aggregate(Statistics stats) Aggregate statistics from a new request
void	flush() Flush the collected stats onto the Forwarder
void	setForwarder(Forwarder forwarder) The forwarder to which the collected statistics need to be forwarded

Methods inherited from class java.lang.Object

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

Constructor Detail

BufferedAggregator

public BufferedAggregator()

Method Detail

aggregate

public void aggregate(Statistics stats)

Description copied from interface: Aggregator

Aggregate statistics from a new request

Specified by:

aggregate in interface Aggregator

Parameters:

stats -

flush

public void flush()

Description copied from interface: Aggregator

Flush the collected stats onto the Forwarder

Specified by:

flush in interface Aggregator

setForwarder

public void setForwarder(Forwarder forwarder)

Description copied from interface: Aggregator

The forwarder to which the collected statistics need to be forwarded

Specified by:

setForwarder in interface Aggregator

Parameters:

forwarder -