ds.funnel.traffic.analysis

Class TrafficReflector

java.lang.Object

ds.funnel.traffic.analysis.TrafficReflector

public class TrafficReflector
extends java.lang.Object

The TrafficReflector should be used in conjunction with a TrafficPublisher. The traffic publisher publishes traffic, and the traffic reflector responds by sending the traffic back so that the traffic publisher can collect statistics on each packet. Subscribes to the named topic designated by TrafficConstants.TOPIC_NAME. Whenever it receives an event not published by itself, simply reflects the event by republishing it, and logs the time (using System nano time) at which the event was received. There is one required command line argument, logFile. This specifies the desired path to the log file. Any time an event is not received within a specified timeout window (more or less), the program will exit. The timeout may be specified (in seconds) as an optional command line argument. If the timeout is not specified it defaults to 5 seconds. Please don't use more than one traffic reflector at a time. Things could get hairy if the traffic reflectors keep reflecting events among themselves.

Author:

Kira Lindburg

Constructor Summary

Constructors

Constructor and Description
TrafficReflector()

Method Summary

Modifier and Type	Method and Description
static void	main(java.lang.String[] args)
static void	onEvent(TopicDataEvent inEvent, long receiveTime) If the inEvent was not published by this traffic reflector, republishes the event to the traffic generation topic.
static void	usage() Prints a usage message.

Methods inherited from class java.lang.Object

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

Constructor Detail

TrafficReflector

public TrafficReflector()

Method Detail

usage

public static void usage()

Prints a usage message.

main

public static void main(java.lang.String[] args)
                 throws OverlayException,
                        TopicException,
                        java.lang.InterruptedException

Throws:

OverlayException

TopicException

java.lang.InterruptedException

onEvent

public static void onEvent(TopicDataEvent inEvent,
                           long receiveTime)
                    throws OverlayException,
                           TopicException

If the inEvent was not published by this traffic reflector, republishes the event to the traffic generation topic.

Parameters:

inEvent - event received

Throws:

TopicException

OverlayException