eu.reservoir.monitoring.distribution.udp
Class UDPDataPlaneConsumerNoNames

java.lang.Object
  eu.reservoir.monitoring.distribution.udp.AbstractUDPDataPlaneConsumer
      eu.reservoir.monitoring.distribution.udp.UDPDataPlaneConsumerNoNames

All Implemented Interfaces:

MeasurementReceiver, MeasurementReporting, DataPlane, DataService, Plane, Receiving

public class UDPDataPlaneConsumerNoNames
extends AbstractUDPDataPlaneConsumer
implements DataPlane, MeasurementReporting, Receiving

Constructor Summary

UDPDataPlaneConsumerNoNames(java.net.InetSocketAddress addr)
Construct a UDPDataPlaneConsumerNoNames.

Method Summary

void	received(java.io.ByteArrayInputStream bis, MetaData metaData) This method is called just after a packet has been received from some underlying transport at a particular address.

Methods inherited from class eu.reservoir.monitoring.distribution.udp.AbstractUDPDataPlaneConsumer

announce, connect, dennounce, disconnect, error, report, sendData, sentData, setMeasurementReceiver

Methods inherited from class java.lang.Object

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

Methods inherited from interface eu.reservoir.monitoring.core.plane.Plane

announce, connect, dennounce, disconnect

Methods inherited from interface eu.reservoir.monitoring.core.plane.DataService

sendData, sentData

Methods inherited from interface eu.reservoir.monitoring.core.MeasurementReceiver

report

Methods inherited from interface eu.reservoir.monitoring.core.MeasurementReporting

setMeasurementReceiver

Methods inherited from interface eu.reservoir.monitoring.distribution.Receiving

error

Constructor Detail

UDPDataPlaneConsumerNoNames

public UDPDataPlaneConsumerNoNames(java.net.InetSocketAddress addr)

Construct a UDPDataPlaneConsumerNoNames.

Method Detail

received

public void received(java.io.ByteArrayInputStream bis,
                     MetaData metaData)
              throws java.io.IOException,
                     TypeException

This method is called just after a packet has been received from some underlying transport at a particular address. The expected message is XDR encoded and it's structure is: +-------------------------------------------------------------------+ | data source id (long) | msg type (int) | seq no (int) | payload | +-------------------------------------------------------------------+

Specified by:

received in interface Receiving

Specified by:

received in class AbstractUDPDataPlaneConsumer

Throws:

java.io.IOException

TypeException