public class AssembledConnectedMessageChannel extends AssembledMessageChannel implements ConnectedMessageChannel
EMPTY| Constructor and Description |
|---|
AssembledConnectedMessageChannel(ConnectedChannel connection,
ReadableMessageChannel readable,
WritableMessageChannel writable)
Construct a new instance.
|
AssembledConnectedMessageChannel(ReadableMessageChannel readable,
WritableMessageChannel writable)
Construct a new instance.
|
| Modifier and Type | Method and Description |
|---|---|
ChannelListener.Setter<? extends AssembledConnectedMessageChannel> |
getCloseSetter()
Get the setter which can be used to change the close listener for this channel.
|
SocketAddress |
getLocalAddress()
Get the local address that this channel is bound to.
|
<A extends SocketAddress> |
getLocalAddress(Class<A> type)
Get the local address of a given type, or
null if the address is not of that
type. |
SocketAddress |
getPeerAddress()
Get the peer address of this channel.
|
<A extends SocketAddress> |
getPeerAddress(Class<A> type)
Get the peer address of a given type, or
null if the address is not of that
type. |
ChannelListener.Setter<? extends AssembledConnectedMessageChannel> |
getReadSetter()
Get the setter which can be used to change the read listener for this channel.
|
ChannelListener.Setter<? extends AssembledConnectedMessageChannel> |
getWriteSetter()
Get the setter which can be used to change the write listener for this channel.
|
awaitReadable, awaitReadable, awaitWritable, awaitWritable, close, flush, getIoThread, getOption, getReadThread, getWorker, getWriteThread, isOpen, isReadResumed, isWriteResumed, receive, receive, receive, resumeReads, resumeWrites, send, send, send, sendFinal, sendFinal, sendFinal, setOption, shutdownReads, shutdownWrites, supportsOption, suspendReads, suspendWrites, wakeupReads, wakeupWritesclone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitreceive, receive, receivesend, send, send, sendFinal, sendFinal, sendFinalawaitReadable, awaitReadable, getReadThread, isReadResumed, resumeReads, shutdownReads, suspendReads, wakeupReadsawaitWritable, awaitWritable, close, flush, getWriteThread, isOpen, isWriteResumed, resumeWrites, shutdownWrites, suspendWrites, wakeupWritesgetIoThread, getWorkergetOption, setOption, supportsOptionpublic AssembledConnectedMessageChannel(ConnectedChannel connection, ReadableMessageChannel readable, WritableMessageChannel writable)
connection - the connected channelreadable - the read channelwritable - the write channelpublic AssembledConnectedMessageChannel(ReadableMessageChannel readable, WritableMessageChannel writable)
readable - the read channelwritable - the write channelpublic ChannelListener.Setter<? extends AssembledConnectedMessageChannel> getCloseSetter()
MessageChannelgetCloseSetter in interface BoundChannelgetCloseSetter in interface CloseableChannelgetCloseSetter in interface ConnectedChannelgetCloseSetter in interface ConnectedMessageChannelgetCloseSetter in interface MessageChannelgetCloseSetter in interface ReadableMessageChannelgetCloseSetter in interface SuspendableChannelgetCloseSetter in interface SuspendableReadChannelgetCloseSetter in interface SuspendableWriteChannelgetCloseSetter in interface WritableMessageChannelgetCloseSetter in class AssembledMessageChannelpublic ChannelListener.Setter<? extends AssembledConnectedMessageChannel> getReadSetter()
MessageChannelgetReadSetter in interface ConnectedMessageChannelgetReadSetter in interface MessageChannelgetReadSetter in interface ReadableMessageChannelgetReadSetter in interface SuspendableChannelgetReadSetter in interface SuspendableReadChannelgetReadSetter in class AssembledMessageChannelpublic ChannelListener.Setter<? extends AssembledConnectedMessageChannel> getWriteSetter()
MessageChannelgetWriteSetter in interface ConnectedMessageChannelgetWriteSetter in interface MessageChannelgetWriteSetter in interface SuspendableChannelgetWriteSetter in interface SuspendableWriteChannelgetWriteSetter in interface WritableMessageChannelgetWriteSetter in class AssembledMessageChannelpublic SocketAddress getPeerAddress()
ConnectedChannelgetPeerAddress in interface ConnectedChannelpublic <A extends SocketAddress> A getPeerAddress(Class<A> type)
ConnectedChannelnull if the address is not of that
type.getPeerAddress in interface ConnectedChanneltype - the address type classnull if unknownpublic SocketAddress getLocalAddress()
BoundChannelgetLocalAddress in interface BoundChannelpublic <A extends SocketAddress> A getLocalAddress(Class<A> type)
BoundChannelnull if the address is not of that
type.getLocalAddress in interface BoundChannelA - the address typetype - the address type classnull if unknownCopyright © 2019 JBoss by Red Hat. All rights reserved.