com.airepublic.multicast

Class MulticastReceiver

java.lang.Object

com.airepublic.multicast.MulticastReceiver

All Implemented Interfaces:

Closeable, AutoCloseable, Runnable

public class MulticastReceiver
extends Object
implements Runnable, Closeable

Receives multicast messages and delegates them to the registered IMulticastMessageHandlers.

Author:

Torsten Oltmanns

Method Summary

Modifier and Type	Method and Description
MulticastReceiver	addMessageHandler(IMulticastMessageHandler handler) Add a IMulticastMessageHandler to handle received messages.
void	close()
static MulticastReceiver	create(InetAddress group, int port, int maxMessageLength) Creates a new MulticastReceiver.
void	removeMessageHandler(IMulticastMessageHandler handler) Remove a IMulticastMessageHandler to handle received messages.
void	run()
MulticastReceiver	start() Start receiving.
void	stop() Stop receiving.

Methods inherited from class java.lang.Object

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

Method Detail

create

public static MulticastReceiver create(InetAddress group,
                                       int port,
                                       int maxMessageLength)

Creates a new MulticastReceiver.

Parameters:

group - the InetAddress to listen on

port - the port to listen on

Returns:

the MulticastReceiver

addMessageHandler

public MulticastReceiver addMessageHandler(IMulticastMessageHandler handler)

Add a IMulticastMessageHandler to handle received messages.

Parameters:

handler - the IMulticastMessageHandler

removeMessageHandler

public void removeMessageHandler(IMulticastMessageHandler handler)

Remove a IMulticastMessageHandler to handle received messages.

Parameters:

handler - the IMulticastMessageHandler

run

public void run()

Specified by:

run in interface Runnable

start

public MulticastReceiver start()

Start receiving.

stop

public void stop()

Stop receiving.

close

public void close()
           throws IOException

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Throws:

IOException