eu.reservoir.monitoring.distribution.udp
Class UDPDataPlaneConsumerWithNames

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

All Implemented Interfaces:

MeasurementReceiver, MeasurementReporting, DataPlane, DataService, Plane, Receiving

Direct Known Subclasses:

UDPDataPlaneConsumer

public class UDPDataPlaneConsumerWithNames
extends AbstractUDPDataPlaneConsumer
implements DataPlane, MeasurementReporting, Receiving

Constructor Summary

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

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

UDPDataPlaneConsumerWithNames

public UDPDataPlaneConsumerWithNames(java.net.InetSocketAddress addr)

Construct a UDPDataPlaneConsumerWithNames.

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