public class NioDatagramChannel extends AbstractChannel implements DatagramChannel
DatagramChannel
.OP_NONE, OP_READ, OP_READ_WRITE, OP_WRITE
Modifier and Type | Method and Description |
---|---|
ChannelFuture |
block(InetAddress multicastAddress,
InetAddress sourceToBlock)
Block the given sourceToBlock address for the given multicastAddress
|
ChannelFuture |
block(InetAddress multicastAddress,
NetworkInterface networkInterface,
InetAddress sourceToBlock)
Block the given sourceToBlock address for the given multicastAddress on the given networkInterface
|
NioDatagramChannelConfig |
getConfig()
Returns the configuration of this channel.
|
protected int |
getInternalInterestOps() |
InetSocketAddress |
getLocalAddress()
Returns the local address where this channel is bound to.
|
InetSocketAddress |
getRemoteAddress()
Returns the remote address where this channel is connected to.
|
NioDatagramWorker |
getWorker()
Return the
AbstractNioWorker that handle the IO of the
AbstractNioChannel |
boolean |
isBound()
Returns
true if and only if this channel is bound to a
local address. |
boolean |
isConnected()
Returns
true if and only if this channel is connected to a
remote address. |
ChannelFuture |
joinGroup(InetAddress multicastAddress)
Joins a multicast group.
|
ChannelFuture |
joinGroup(InetAddress multicastAddress,
NetworkInterface networkInterface,
InetAddress source)
Joins the specified multicast group at the specified interface using the specified source.
|
ChannelFuture |
joinGroup(InetSocketAddress multicastAddress,
NetworkInterface networkInterface)
Joins the specified multicast group at the specified interface.
|
ChannelFuture |
leaveGroup(InetAddress multicastAddress)
Leaves a multicast group.
|
ChannelFuture |
leaveGroup(InetAddress multicastAddress,
NetworkInterface networkInterface,
InetAddress source)
Leave the specified multicast group at the specified interface using the specified source.
|
ChannelFuture |
leaveGroup(InetSocketAddress multicastAddress,
NetworkInterface networkInterface)
Leaves a multicast group on a specified local interface.
|
protected boolean |
setClosed()
Marks this channel as closed.
|
protected void |
setInternalInterestOps(int interestOps)
Sets the
interestOps property of this channel
immediately. |
ChannelFuture |
write(Object message,
SocketAddress remoteAddress)
Sends a message to this channel asynchronously.
|
bind, close, compareTo, connect, disconnect, equals, getAttachment, getCloseFuture, getFactory, getId, getInterestOps, getParent, getPipeline, getSucceededFuture, getUnsupportedOperationFuture, getUserDefinedWritability, hashCode, isOpen, isReadable, isWritable, setAttachment, setInterestOps, setReadable, setUnwritable, setUserDefinedWritability, setWritable, toString, unbind, write
clone, finalize, getClass, notify, notifyAll, wait, wait, wait
getLocalAddress, getRemoteAddress
bind, close, connect, disconnect, getAttachment, getCloseFuture, getFactory, getId, getInterestOps, getParent, getPipeline, getUserDefinedWritability, isOpen, isReadable, isWritable, setAttachment, setInterestOps, setReadable, setUserDefinedWritability, unbind, write
compareTo
public NioDatagramWorker getWorker()
AbstractNioWorker
that handle the IO of the
AbstractNioChannel
public boolean isBound()
Channel
true
if and only if this channel is bound to a
local address.public boolean isConnected()
Channel
true
if and only if this channel is connected to a
remote address.isConnected
in interface Channel
protected boolean setClosed()
AbstractChannel
true
if and only if this channel was not marked as
closed yetpublic NioDatagramChannelConfig getConfig()
Channel
getConfig
in interface Channel
getConfig
in interface DatagramChannel
public ChannelFuture joinGroup(InetAddress multicastAddress)
DatagramChannel
joinGroup
in interface DatagramChannel
public ChannelFuture joinGroup(InetSocketAddress multicastAddress, NetworkInterface networkInterface)
DatagramChannel
joinGroup
in interface DatagramChannel
public ChannelFuture joinGroup(InetAddress multicastAddress, NetworkInterface networkInterface, InetAddress source)
public ChannelFuture leaveGroup(InetAddress multicastAddress)
DatagramChannel
leaveGroup
in interface DatagramChannel
public ChannelFuture leaveGroup(InetSocketAddress multicastAddress, NetworkInterface networkInterface)
DatagramChannel
leaveGroup
in interface DatagramChannel
public ChannelFuture leaveGroup(InetAddress multicastAddress, NetworkInterface networkInterface, InetAddress source)
public ChannelFuture block(InetAddress multicastAddress, NetworkInterface networkInterface, InetAddress sourceToBlock)
public ChannelFuture block(InetAddress multicastAddress, InetAddress sourceToBlock)
public ChannelFuture write(Object message, SocketAddress remoteAddress)
Channel
DatagramChannel
)
and is not connected yet, you must specify non-null address. Otherwise,
the write request will fail with NotYetConnectedException
and
an 'exceptionCaught'
event will be triggered.write
in interface Channel
write
in class AbstractChannel
message
- the message to writeremoteAddress
- where to send the specified message.
This method is identical to Channel.write(Object)
if null
is specified here.ChannelFuture
which will be notified when the
write request succeeds or failspublic InetSocketAddress getLocalAddress()
Channel
SocketAddress
is supposed to be down-cast into more concrete
type such as InetSocketAddress
to retrieve the detailed
information.null
if this channel is not bound.public InetSocketAddress getRemoteAddress()
Channel
SocketAddress
is supposed to be down-cast into more
concrete type such as InetSocketAddress
to retrieve the detailed
information.null
if this channel is not connected.
If this channel is not connected but it can receive messages
from arbitrary remote addresses (e.g. DatagramChannel
,
use MessageEvent.getRemoteAddress()
to determine
the origination of the received message as this method will
return null
.protected int getInternalInterestOps()
getInternalInterestOps
in class AbstractChannel
protected void setInternalInterestOps(int interestOps)
AbstractChannel
interestOps
property of this channel
immediately. This method is intended to be called by an internal
component - please do not call it unless you know what you are doing.setInternalInterestOps
in class AbstractChannel
Copyright © 2008-2016 The Netty Project. All Rights Reserved.