public abstract class DatagramServer<IN,OUT> extends ReactorPeer<IN,OUT,ChannelStream<IN,OUT>>
started
Modifier | Constructor and Description |
---|---|
protected |
DatagramServer(Environment env,
Dispatcher dispatcher,
InetSocketAddress listenAddress,
NetworkInterface multicastInterface,
ServerSocketOptions options,
Codec<Buffer,IN,OUT> codec) |
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.
|
doShutdown, doStart, getDefaultCodec, getDefaultDispatcher, getDefaultEnvironment, getDefaultPrefetchSize, shutdown, start
protected DatagramServer(Environment env, Dispatcher dispatcher, InetSocketAddress listenAddress, NetworkInterface multicastInterface, ServerSocketOptions options, Codec<Buffer,IN,OUT> codec)
public abstract Promise<Void> join(InetAddress multicastAddress, NetworkInterface iface)
multicastAddress
- multicast address of the group to joiniface
- interface to use for multicastPromise
that will be complete when the group has been joinedpublic Promise<Void> join(InetAddress multicastAddress)
multicastAddress
- multicast address of the group to joinPromise
that will be complete when the group has been joinedpublic abstract Promise<Void> leave(InetAddress multicastAddress, NetworkInterface iface)
multicastAddress
- multicast address of the group to leaveiface
- interface to use for multicastPromise
that will be complete when the group has been leftpublic Promise<Void> leave(InetAddress multicastAddress)
multicastAddress
- multicast address of the group to leavePromise
that will be complete when the group has been leftprotected InetSocketAddress getListenAddress()
protected NetworkInterface getMulticastInterface()
NetworkInterface
on which multicast will be performed.protected ServerSocketOptions getOptions()
ServerSocketOptions
currently in effect.Copyright © 2017. All rights reserved.