public class RxtxChannel extends OioByteStreamChannel
AbstractChannel.AbstractUnsafe
Channel.Unsafe
SO_TIMEOUT
Constructor and Description |
---|
RxtxChannel() |
Modifier and Type | Method and Description |
---|---|
RxtxChannelConfig |
config()
Returns the configuration of this channel.
|
protected void |
doBind(SocketAddress localAddress)
Bind the
Channel to the SocketAddress |
protected void |
doClose()
Close the
Channel |
protected void |
doConnect(SocketAddress remoteAddress,
SocketAddress localAddress)
Connect to the remote peer using the given localAddress if one is specified or
null otherwise. |
protected void |
doDisconnect()
Disconnect this
Channel from its remote peer |
protected void |
doInit() |
boolean |
isOpen()
Returns
true if the Channel is open an may get active later |
RxtxDeviceAddress |
localAddress()
Returns the local address where this channel is bound to.
|
protected RxtxDeviceAddress |
localAddress0()
Returns the
SocketAddress which is bound locally. |
protected AbstractChannel.AbstractUnsafe |
newUnsafe()
Create a new
AbstractChannel.AbstractUnsafe instance which will be used for the life-time of the Channel |
RxtxDeviceAddress |
remoteAddress()
Returns the remote address where this channel is connected to.
|
protected RxtxDeviceAddress |
remoteAddress0()
Return the
SocketAddress which the Channel is connected to. |
activate, available, doReadBytes, doWriteBytes, doWriteFileRegion, isActive
checkInputShutdown, doRead, doWrite, filterOutboundMessage, isInputShutdown, metadata
doBeginRead, isCompatible, isReadPending, setReadPending
alloc, bind, bind, close, close, closeFuture, compareTo, connect, connect, connect, connect, deregister, deregister, disconnect, disconnect, doDeregister, doRegister, equals, eventLoop, flush, hashCode, id, invalidateLocalAddress, invalidateRemoteAddress, isRegistered, isWritable, newFailedFuture, newProgressivePromise, newPromise, newSucceededFuture, parent, pipeline, read, toString, unsafe, voidPromise, write, write, writeAndFlush, writeAndFlush
attr, hasAttr
clone, finalize, getClass, notify, notifyAll, wait, wait, wait
attr, hasAttr
public RxtxChannelConfig config()
Channel
public boolean isOpen()
Channel
true
if the Channel
is open an may get active laterprotected AbstractChannel.AbstractUnsafe newUnsafe()
AbstractChannel
AbstractChannel.AbstractUnsafe
instance which will be used for the life-time of the Channel
newUnsafe
in class AbstractOioChannel
protected void doConnect(SocketAddress remoteAddress, SocketAddress localAddress) throws Exception
AbstractOioChannel
null
otherwise.doConnect
in class AbstractOioChannel
Exception
public RxtxDeviceAddress localAddress()
Channel
SocketAddress
is supposed to be down-cast into more concrete
type such as InetSocketAddress
to retrieve the detailed
information.localAddress
in interface Channel
localAddress
in class AbstractChannel
null
if this channel is not bound.public RxtxDeviceAddress remoteAddress()
Channel
SocketAddress
is supposed to be down-cast into more
concrete type such as InetSocketAddress
to retrieve the detailed
information.remoteAddress
in interface Channel
remoteAddress
in class AbstractChannel
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 DefaultAddressedEnvelope.recipient()
to determine
the origination of the received message as this method will
return null
.protected RxtxDeviceAddress localAddress0()
AbstractChannel
SocketAddress
which is bound locally.localAddress0
in class AbstractChannel
protected RxtxDeviceAddress remoteAddress0()
AbstractChannel
SocketAddress
which the Channel
is connected to.remoteAddress0
in class AbstractChannel
protected void doBind(SocketAddress localAddress) throws Exception
AbstractChannel
Channel
to the SocketAddress
doBind
in class AbstractChannel
Exception
protected void doDisconnect() throws Exception
AbstractChannel
Channel
from its remote peerdoDisconnect
in class AbstractChannel
Exception
protected void doClose() throws Exception
AbstractChannel
Channel
doClose
in class OioByteStreamChannel
Exception
Copyright © 2008–2015 The Netty Project. All rights reserved.