Deprecated
use NIO / EPOLL / KQUEUE transport.
Channel that sends and receives an
AddressedEnvelope<ByteBuf, SocketAddress>.
AddressedEnvelope, DatagramPacket
| Modifier and Type | Field and Description |
|---|---|
| private final OioDatagramChannelConfig | config
Deprecated
as a consequence of
OioDatagramChannelConfig being deprecated.
|
| private static final String | |
| private static final InternalLogger | |
| private static final ChannelMetadata | |
| private final MulticastSocket | |
| private final DatagramPacket |
| Access | Constructor and Description |
|---|---|
| public | |
| public | OioDatagramChannel(MulticastSocket
the socket)MulticastSocket which is used by this instanceCreate a new instance from the given |
| Modifier and Type | Method and Description |
|---|---|
| public ChannelFuture | block(InetAddress multicastAddress, NetworkInterface networkInterface, InetAddress sourceToBlock)
Implements io. ChannelFuture once the operation completes.
|
| public ChannelFuture | block(InetAddress multicastAddress, NetworkInterface networkInterface, InetAddress sourceToBlock, ChannelPromise promise)
Implements io. ChannelFuture once the operation completes.
|
| public ChannelFuture | block(InetAddress multicastAddress, InetAddress sourceToBlock)
Implements io. ChannelFuture once
the operation completes.
|
| public ChannelFuture | block(InetAddress multicastAddress, InetAddress sourceToBlock, ChannelPromise promise)
Implements io. ChannelFuture once
the operation completes.
|
| private static void | |
| public DatagramChannelConfig | config()
Implements io. |
| protected void | doBind(SocketAddress localAddress)
Implements abstract io. Channel to the SocketAddress
|
| protected void | |
| protected void | doConnect(SocketAddress remoteAddress, SocketAddress localAddress)
Implements abstract io. null otherwise.
|
| protected void | doDisconnect()
Implements abstract io. Channel from its remote peer
|
| protected int | doReadMessages(List<Object> buf)
Implements abstract io. |
| protected void | doWrite(ChannelOutboundBuffer in)
Implements abstract io. |
| private void | |
| protected Object | filterOutboundMessage(Object msg)
Overrides io. ChannelOutboundBuffer of this AbstractChannel, so that
the Channel implementation converts the message to another.
|
| public boolean | isActive()
Implements io. true if the Channel is active and so connected.
|
| public boolean | isConnected()
Implements io. true if the DatagramChannel is connected to the remote peer.
|
| public boolean | isOpen()
Implements io. true if the Channel is open and may get active later
|
| public ChannelFuture | joinGroup(InetAddress multicastAddress)
Implements io. ChannelFuture once the operation completes.
|
| public ChannelFuture | joinGroup(InetAddress multicastAddress, ChannelPromise promise)
Implements io. ChannelFuture once the operation completes.
|
| public ChannelFuture | joinGroup(InetSocketAddress multicastAddress, NetworkInterface networkInterface)
Implements io. ChannelFuture
once the operation completes.
|
| public ChannelFuture | joinGroup(InetSocketAddress multicastAddress, NetworkInterface networkInterface, ChannelPromise promise)
Implements io. ChannelFuture
once the operation completes.
|
| public ChannelFuture | joinGroup(InetAddress multicastAddress, NetworkInterface networkInterface, InetAddress source)
Implements io. ChannelFuture
once the operation completes.
|
| public ChannelFuture | joinGroup(InetAddress multicastAddress, NetworkInterface networkInterface, InetAddress source, ChannelPromise promise)
Implements io. ChannelFuture
once the operation completes.
|
| public ChannelFuture | leaveGroup(InetAddress multicastAddress)
Implements io. ChannelFuture once the operation completes.
|
| public ChannelFuture | leaveGroup(InetAddress multicastAddress, ChannelPromise promise)
Implements io. ChannelFuture once the operation completes.
|
| public ChannelFuture | leaveGroup(InetSocketAddress multicastAddress, NetworkInterface networkInterface)
Implements io. ChannelFuture once the
operation completes.
|
| public ChannelFuture | leaveGroup(InetSocketAddress multicastAddress, NetworkInterface networkInterface, ChannelPromise promise)
Implements io. ChannelFuture once the
operation completes.
|
| public ChannelFuture | leaveGroup(InetAddress multicastAddress, NetworkInterface networkInterface, InetAddress source)
Implements io. ChannelFuture once the operation completes.
|
| public ChannelFuture | leaveGroup(InetAddress multicastAddress, NetworkInterface networkInterface, InetAddress source, ChannelPromise promise)
Implements io. ChannelFuture once the operation completes.
|
| public InetSocketAddress | localAddress()
Overrides io. Implements io. |
| protected SocketAddress | localAddress0()
Implements abstract io. SocketAddress which is bound locally.
|
| public ChannelMetadata | metadata()
Implements io. ChannelMetadata of the Channel which describe the nature of the Channel.
|
| private static MulticastSocket | |
| public InetSocketAddress | remoteAddress()
Overrides io. Implements io. |
| protected SocketAddress | remoteAddress0()
Implements abstract io. SocketAddress which the Channel is connected to.
|
| config | back to summary |
|---|---|
| private final OioDatagramChannelConfig config
Deprecated as a consequence of | |
| EXPECTED_TYPES | back to summary |
|---|---|
| private static final String EXPECTED_TYPES | |
| logger | back to summary |
|---|---|
| private static final InternalLogger logger | |
| METADATA | back to summary |
|---|---|
| private static final ChannelMetadata METADATA | |
| socket | back to summary |
|---|---|
| private final MulticastSocket socket | |
| tmpPacket | back to summary |
|---|---|
| private final DatagramPacket tmpPacket | |
| OioDatagramChannel | back to summary |
|---|---|
| public OioDatagramChannel() Create a new instance with an new | |
| OioDatagramChannel | back to summary |
|---|---|
| public OioDatagramChannel(MulticastSocket socket) Create a new instance from the given
| |
| block | back to summary |
|---|---|
| public ChannelFuture block(InetAddress multicastAddress, NetworkInterface networkInterface, InetAddress sourceToBlock) Implements io. Doc from io. Block the given sourceToBlock address for the given multicastAddress on the given networkInterface and notifies
the
| |
| block | back to summary |
|---|---|
| public ChannelFuture block(InetAddress multicastAddress, NetworkInterface networkInterface, InetAddress sourceToBlock, ChannelPromise promise) Implements io. Doc from io. Block the given sourceToBlock address for the given multicastAddress on the given networkInterface and notifies
the
| |
| block | back to summary |
|---|---|
| public ChannelFuture block(InetAddress multicastAddress, InetAddress sourceToBlock) Implements io. Doc from io. Block the given sourceToBlock address for the given multicastAddress and notifies the
| |
| block | back to summary |
|---|---|
| public ChannelFuture block(InetAddress multicastAddress, InetAddress sourceToBlock, ChannelPromise promise) Implements io. Doc from io. Block the given sourceToBlock address for the given multicastAddress and notifies the
| |
| checkUnresolved | back to summary |
|---|---|
| private static void checkUnresolved(AddressedEnvelope<?, ?> envelope) | |
| config | back to summary |
|---|---|
| public DatagramChannelConfig config() Implements io. Doc from io. Returns the configuration of this channel.
This can be safely cast to
| |
| doBind | back to summary |
|---|---|
| protected void doBind(SocketAddress localAddress) throws Exception Implements abstract io. Doc from io. Bind the
| |
| doClose | back to summary |
|---|---|
| protected void doClose() throws Exception Implements abstract io. Doc from io. Close the
| |
| doConnect | back to summary |
|---|---|
| protected void doConnect(SocketAddress remoteAddress, SocketAddress localAddress) throws Exception Implements abstract io. Doc from io. Connect to the remote peer using the given localAddress if one is specified or
| |
| doDisconnect | back to summary |
|---|---|
| protected void doDisconnect() throws Exception Implements abstract io. Doc from io. Disconnect this
| |
| doReadMessages | back to summary |
|---|---|
| protected int doReadMessages(List<Object> buf) throws Exception Implements abstract io. Doc from io. Read messages into the given array and return the amount which was read.
| |
| doWrite | back to summary |
|---|---|
| protected void doWrite(ChannelOutboundBuffer in) throws Exception Implements abstract io. Doc from io. Flush the content of the given buffer to the remote peer.
| |
| ensureBound | back to summary |
|---|---|
| private void ensureBound() | |
| filterOutboundMessage | back to summary |
|---|---|
| protected Object filterOutboundMessage(Object msg) Overrides io. Doc from io. Invoked when a new message is added to a
| |
| isActive | back to summary |
|---|---|
| public boolean isActive() Implements io. Doc from io. Return
| |
| isConnected | back to summary |
|---|---|
| public boolean isConnected() Implements io. Doc from io. Return
| |
| isOpen | back to summary |
|---|---|
| public boolean isOpen() Implements io. Doc from io. Returns
| |
| joinGroup | back to summary |
|---|---|
| public ChannelFuture joinGroup(InetAddress multicastAddress) Implements io. Doc from io. Joins a multicast group and notifies the
| |
| joinGroup | back to summary |
|---|---|
| public ChannelFuture joinGroup(InetAddress multicastAddress, ChannelPromise promise) Implements io. Doc from io. Joins a multicast group and notifies the
| |
| joinGroup | back to summary |
|---|---|
| public ChannelFuture joinGroup(InetSocketAddress multicastAddress, NetworkInterface networkInterface) Implements io. Doc from io. Joins the specified multicast group at the specified interface and notifies the
| |
| joinGroup | back to summary |
|---|---|
| public ChannelFuture joinGroup(InetSocketAddress multicastAddress, NetworkInterface networkInterface, ChannelPromise promise) Implements io. Doc from io. Joins the specified multicast group at the specified interface and notifies the
| |
| joinGroup | back to summary |
|---|---|
| public ChannelFuture joinGroup(InetAddress multicastAddress, NetworkInterface networkInterface, InetAddress source) Implements io. Doc from io. Joins the specified multicast group at the specified interface and notifies the
| |
| joinGroup | back to summary |
|---|---|
| public ChannelFuture joinGroup(InetAddress multicastAddress, NetworkInterface networkInterface, InetAddress source, ChannelPromise promise) Implements io. Doc from io. Joins the specified multicast group at the specified interface and notifies the
| |
| leaveGroup | back to summary |
|---|---|
| public ChannelFuture leaveGroup(InetAddress multicastAddress) Implements io. Doc from io. Leaves a multicast group and notifies the
| |
| leaveGroup | back to summary |
|---|---|
| public ChannelFuture leaveGroup(InetAddress multicastAddress, ChannelPromise promise) Implements io. Doc from io. Leaves a multicast group and notifies the
| |
| leaveGroup | back to summary |
|---|---|
| public ChannelFuture leaveGroup(InetSocketAddress multicastAddress, NetworkInterface networkInterface) Implements io. Doc from io. Leaves a multicast group on a specified local interface and notifies the
| |
| leaveGroup | back to summary |
|---|---|
| public ChannelFuture leaveGroup(InetSocketAddress multicastAddress, NetworkInterface networkInterface, ChannelPromise promise) Implements io. Doc from io. Leaves a multicast group on a specified local interface and notifies the
| |
| leaveGroup | back to summary |
|---|---|
| public ChannelFuture leaveGroup(InetAddress multicastAddress, NetworkInterface networkInterface, InetAddress source) Implements io. Doc from io. Leave the specified multicast group at the specified interface using the specified source and notifies
the
| |
| leaveGroup | back to summary |
|---|---|
| public ChannelFuture leaveGroup(InetAddress multicastAddress, NetworkInterface networkInterface, InetAddress source, ChannelPromise promise) Implements io. Doc from io. Leave the specified multicast group at the specified interface using the specified source and notifies
the
| |
| localAddress | back to summary |
|---|---|
| public InetSocketAddress localAddress() Overrides io. Implements io. Doc from io. Returns the local address where this channel is bound to. The returned
| |
| localAddress0 | back to summary |
|---|---|
| protected SocketAddress localAddress0() Implements abstract io. Doc from io. Returns the
| |
| metadata | back to summary |
|---|---|
| public ChannelMetadata metadata() Implements io. Doc from io. Return the
| |
| newSocket | back to summary |
|---|---|
| private static MulticastSocket newSocket() | |
| remoteAddress | back to summary |
|---|---|
| public InetSocketAddress remoteAddress() Overrides io. Implements io. Doc from io. Returns the remote address where this channel is connected to. The
returned
| |
| remoteAddress0 | back to summary |
|---|---|
| protected SocketAddress remoteAddress0() Implements abstract io. Doc from io. Return the
| |