eu.reservoir.monitoring.distribution.multicast
Class MulticastDataPlaneConsumerNoNames

java.lang.Object
  extended by eu.reservoir.monitoring.distribution.multicast.AbstractMulticastDataPlaneConsumer
      extended by eu.reservoir.monitoring.distribution.multicast.MulticastDataPlaneConsumerWithNames
          extended by eu.reservoir.monitoring.distribution.multicast.MulticastDataPlaneConsumer
              extended by eu.reservoir.monitoring.distribution.multicast.MulticastDataPlaneConsumerNoNames
All Implemented Interfaces:
MeasurementReceiver, MeasurementReporting, DataPlane, DataService, Plane, Receiving

public class MulticastDataPlaneConsumerNoNames
extends MulticastDataPlaneConsumer
implements DataPlane, MeasurementReporting, Receiving

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


Constructor Summary
MulticastDataPlaneConsumerNoNames(MulticastAddress addr)
          Construct a MulticastDataPlaneConsumerNoNames
 
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

MulticastDataPlaneConsumerNoNames

public MulticastDataPlaneConsumerNoNames(MulticastAddress addr)
Construct a MulticastDataPlaneConsumerNoNames

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
Overrides:
received in class MulticastDataPlaneConsumerWithNames
Throws:
java.io.IOException
TypeException


RESERVOIR Monitoring 0.6.4