plugins_usr.aggregator.test

Class InfoConsumer

java.lang.Object

plugins_usr.aggregator.test.InfoConsumer

All Implemented Interfaces:

eu.reservoir.monitoring.core.Reporter, java.util.EventListener

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

An InfoConsumer that can receive measurements. Has args: input mulitcast 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.
static void	main(java.lang.String[] args) Main entry point.
void	report(eu.reservoir.monitoring.core.Measurement m) Receiver of a measurment.
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.
void	start() Start the InfoConsumer.

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

start

public void start()

Start the InfoConsumer.

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.

main

public static void main(java.lang.String[] args)

Main entry point. Args are: -i input address (default: @(0)/2299) -l log path, (default: /tmp/) -n name (default: "info-consumer")