eu.reservoir.monitoring.distribution.multicast
Class MulticastDataPlaneConsumerWithNames

java.lang.Object
  eu.reservoir.monitoring.distribution.multicast.AbstractMulticastDataPlaneConsumer
      eu.reservoir.monitoring.distribution.multicast.MulticastDataPlaneConsumerWithNames

All Implemented Interfaces:

MeasurementReceiver, MeasurementReporting, DataPlane, DataService, Plane, Receiving

Direct Known Subclasses:

MulticastDataPlaneConsumer

public class MulticastDataPlaneConsumerWithNames
extends AbstractMulticastDataPlaneConsumer
implements DataPlane, MeasurementReporting, Receiving

A MulticastDataPlaneConsumerWithNames is a DataPlane implementation that receives Measurements by multicast.

Constructor Summary

MulticastDataPlaneConsumerWithNames(MulticastAddress addr)
Construct a MulticastDataPlaneConsumerWithNames.

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 multicast address.

Methods inherited from class eu.reservoir.monitoring.distribution.multicast.AbstractMulticastDataPlaneConsumer

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

MulticastDataPlaneConsumerWithNames

public MulticastDataPlaneConsumerWithNames(MulticastAddress addr)

Construct a MulticastDataPlaneConsumerWithNames.

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 multicast 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 AbstractMulticastDataPlaneConsumer

Throws:

java.io.IOException

TypeException