plugins_usr.aggregator.appl

Class InfoConsumer

java.lang.Object

plugins_usr.aggregator.appl.InfoConsumer

All Implemented Interfaces:

eu.reservoir.monitoring.core.Reporter, java.lang.Runnable, java.util.EventListener, Application

public class InfoConsumer
extends java.lang.Object
implements eu.reservoir.monitoring.core.Reporter, Application

An InfoConsumer that can receive measurements. Has args: input addr logpath - the path to log into

Constructor Summary

Constructors

Constructor and Description
InfoConsumer() InfoConsumer constructor.

Method Summary

Methods

Modifier and Type	Method and Description
java.lang.String	getCollectionPath() Get the path where raw data is collected into.
SocketAddress	getInputAddress() Get the address for inpput traffic.
java.lang.String	getName() Get the name of the AggPoint.
ApplicationResponse	init(java.lang.String[] args) init Args are: -i input address -l log path, (default: /tmp/) -n name (default: "info-consumer")
void	report(eu.reservoir.monitoring.core.Measurement m) Receiver of a measurment.
void	run() Run
java.lang.String	setCollectionPath(java.lang.String path) Set the path where raw data is collected into.
SocketAddress	setInputAddress(SocketAddress in) Set the address for input traffic.
java.lang.String	setName(java.lang.String str) Set the name of the AggPoint.
ApplicationResponse	start() Start the InfoConsumer.
ApplicationResponse	stop() Stop

Methods inherited from class java.lang.Object

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

Constructor Detail

InfoConsumer

public InfoConsumer()

InfoConsumer constructor.

Method Detail

init

public ApplicationResponse init(java.lang.String[] args)

init Args are: -i input address -l log path, (default: /tmp/) -n name (default: "info-consumer")

Specified by:

init in interface Application

start

public ApplicationResponse start()

Start the InfoConsumer.

Specified by:

start in interface Application

stop

public ApplicationResponse stop()

Stop

Specified by:

stop in interface Application

run

public void run()

Run

Specified by:

run in interface java.lang.Runnable

report

public void report(eu.reservoir.monitoring.core.Measurement m)

Receiver of a measurment.

Specified by:

report in interface eu.reservoir.monitoring.core.Reporter

getInputAddress

public SocketAddress getInputAddress()

Get the address for inpput traffic.

setInputAddress

public SocketAddress setInputAddress(SocketAddress in)

Set the address for input traffic.

getCollectionPath

public java.lang.String getCollectionPath()

Get the path where raw data is collected into.

setCollectionPath

public java.lang.String setCollectionPath(java.lang.String path)

Set the path where raw data is collected into.

getName

public java.lang.String getName()

Get the name of the AggPoint.

setName

public java.lang.String setName(java.lang.String str)

Set the name of the AggPoint.