eu.reservoir.monitoring.distribution.multicast
Class MulticastReceiver

java.lang.Object
  eu.reservoir.monitoring.distribution.multicast.MulticastReceiver

All Implemented Interfaces:

java.lang.Runnable

public class MulticastReceiver
extends java.lang.Object
implements java.lang.Runnable

This is a multicast receiver for monitoring messages.

Constructor Summary

MulticastReceiver(Receiving receiver, MulticastAddress mcastAddr)
Construct a receiver for a particular multicast address

Method Summary

void	join() Join the address now and start listening
void	leave() Leave the address now and stop listening
protected boolean	receive() Receive a message from the multicast address.
void	run() The Runnable body

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

MulticastReceiver

public MulticastReceiver(Receiving receiver,
                         MulticastAddress mcastAddr)
                  throws java.io.IOException

Construct a receiver for a particular multicast address

Throws:

java.io.IOException

Method Detail

join

public void join()
          throws java.io.IOException

Join the address now and start listening

Throws:

java.io.IOException

leave

public void leave()
           throws java.io.IOException

Leave the address now and stop listening

Throws:

java.io.IOException

receive

protected boolean receive()

Receive a message from the multicast address.

run

public void run()

The Runnable body

Specified by:

run in interface java.lang.Runnable