reactor.io.net.udp

Class DatagramServer<IN,OUT>

java.lang.Object

reactor.io.net.ReactorPeer<IN,OUT,ChannelStream<IN,OUT>>

reactor.io.net.udp.DatagramServer<IN,OUT>

Direct Known Subclasses:

NettyDatagramServer

public abstract class DatagramServer<IN,OUT>
extends ReactorPeer<IN,OUT,ChannelStream<IN,OUT>>

Author:

Jon Brisbin, Stephane Maldini

Field Summary

Fields inherited from class reactor.io.net.ReactorPeer

started

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	DatagramServer(Environment env, Dispatcher dispatcher, InetSocketAddress listenAddress, NetworkInterface multicastInterface, ServerSocketOptions options, Codec<Buffer,IN,OUT> codec)

Method Summary

Modifier and Type	Method and Description
protected InetSocketAddress	getListenAddress() Get the address to which this server is bound.
protected NetworkInterface	getMulticastInterface() Get the NetworkInterface on which multicast will be performed.
protected ServerSocketOptions	getOptions() Get the ServerSocketOptions currently in effect.
Promise<Void>	join(InetAddress multicastAddress) Join a multicast group.
abstract Promise<Void>	join(InetAddress multicastAddress, NetworkInterface iface) Join a multicast group.
Promise<Void>	leave(InetAddress multicastAddress) Leave a multicast group.
abstract Promise<Void>	leave(InetAddress multicastAddress, NetworkInterface iface) Leave a multicast group.

Methods inherited from class reactor.io.net.ReactorPeer

doShutdown, doStart, getDefaultCodec, getDefaultDispatcher, getDefaultEnvironment, getDefaultPrefetchSize, shutdown, start

Methods inherited from class java.lang.Object

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

Constructor Detail

DatagramServer

protected DatagramServer(Environment env,
                         Dispatcher dispatcher,
                         InetSocketAddress listenAddress,
                         NetworkInterface multicastInterface,
                         ServerSocketOptions options,
                         Codec<Buffer,IN,OUT> codec)

Method Detail

join

public abstract Promise<Void> join(InetAddress multicastAddress,
                                   NetworkInterface iface)

Join a multicast group.

Parameters:

multicastAddress - multicast address of the group to join

iface - interface to use for multicast

Returns:

a Promise that will be complete when the group has been joined

join

public Promise<Void> join(InetAddress multicastAddress)

Join a multicast group.

Parameters:

multicastAddress - multicast address of the group to join

Returns:

a Promise that will be complete when the group has been joined

leave

public abstract Promise<Void> leave(InetAddress multicastAddress,
                                    NetworkInterface iface)

Leave a multicast group.

Parameters:

multicastAddress - multicast address of the group to leave

iface - interface to use for multicast

Returns:

a Promise that will be complete when the group has been left

leave

public Promise<Void> leave(InetAddress multicastAddress)

Leave a multicast group.

Parameters:

multicastAddress - multicast address of the group to leave

Returns:

a Promise that will be complete when the group has been left

getListenAddress

protected InetSocketAddress getListenAddress()

Get the address to which this server is bound.

Returns:

the bind address

getMulticastInterface

protected NetworkInterface getMulticastInterface()

Get the NetworkInterface on which multicast will be performed.

Returns:

the multicast NetworkInterface

getOptions

protected ServerSocketOptions getOptions()

Get the ServerSocketOptions currently in effect.

Returns:

the server options in use