eu.reservoir.monitoring.distribution.multicast
Class MulticastDataPlaneConsumerWithNames

java.lang.Object
  extended by eu.reservoir.monitoring.distribution.multicast.AbstractMulticastDataPlaneConsumer
      extended by 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


RESERVOIR Monitoring 0.6.4