eu.reservoir.monitoring.distribution.multicast
Class MulticastDataPlaneProducerWithNames

java.lang.Object
  eu.reservoir.monitoring.distribution.multicast.AbstractMulticastDataPlaneProducer
      eu.reservoir.monitoring.distribution.multicast.MulticastDataPlaneProducerWithNames

All Implemented Interfaces:

DataSourceDelegateInteracter, MeasurementReceiver, DataPlane, DataService, Plane, Transmitting

Direct Known Subclasses:

MulticastDataPlaneProducer

public class MulticastDataPlaneProducerWithNames
extends AbstractMulticastDataPlaneProducer
implements DataPlane, DataSourceDelegateInteracter, Transmitting

A MulticastDataPlaneProducerWithNames is a DataPlane implementation that sends Measurements by multicast. It is also a DataSourceDelegateInteracter so it can, if needed, talk to the DataSource object it gets bound to.

Constructor Summary

MulticastDataPlaneProducerWithNames(MulticastAddress addr)
Construct a MulticastDataPlaneProducerWithNames.

Method Summary

int	transmit(DataPlaneMessage dpm) Send a message onto the multicast address.

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

announce, connect, dennounce, disconnect, getDataSourceDelegate, report, sendData, sentData, setDataSourceDelegate, transmitted

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.DataSourceDelegateInteracter

getDataSourceDelegate, setDataSourceDelegate

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

transmitted

Constructor Detail

MulticastDataPlaneProducerWithNames

public MulticastDataPlaneProducerWithNames(MulticastAddress addr)

Construct a MulticastDataPlaneProducerWithNames.

Method Detail

transmit

public int transmit(DataPlaneMessage dpm)
             throws java.lang.Exception

Send a message onto the multicast address. The message is XDR encoded and it's structure is: +-------------------------------------------------------------------+ | data source id (long) | msg type (int) | seq no (int) | payload | +-------------------------------------------------------------------+

Specified by:

transmit in interface Transmitting

Specified by:

transmit in class AbstractMulticastDataPlaneProducer

Throws:

java.lang.Exception