public abstract class MessageConnection extends Connection implements CloseListenerSettable<MessageConnection>
CloseListenerSettable.Setter<C extends Channel>
thread
EMPTY
Modifier | Constructor and Description |
---|---|
protected |
MessageConnection(XnioIoThread thread)
Construct a new instance.
|
Modifier and Type | Method and Description |
---|---|
ChannelListener<? super MessageConnection> |
getCloseListener()
Get the close listener.
|
ChannelListener.Setter<MessageConnection> |
getCloseSetter()
Get the setter which can be used to change the close listener for this channel.
|
ConduitWritableMessageChannel |
getSinkChannel()
Get the sink channel.
|
ConduitReadableMessageChannel |
getSourceChannel()
Get the source channel.
|
void |
setCloseListener(ChannelListener<? super MessageConnection> listener)
Set the close listener.
|
protected void |
setSinkConduit(MessageSinkConduit conduit) |
protected void |
setSourceConduit(MessageSourceConduit conduit) |
close, closeAction, getIoThread, getLocalAddress, getOption, getPeerAddress, getWorker, isOpen, isReadShutdown, isWriteShutdown, notifyReadClosed, notifyWriteClosed, readClosed, setOption, supportsOption, writeClosed
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getPeerAddress
getLocalAddress
protected MessageConnection(XnioIoThread thread)
thread
- the I/O threadpublic void setCloseListener(ChannelListener<? super MessageConnection> listener)
CloseListenerSettable
setCloseListener
in interface CloseListenerSettable<MessageConnection>
listener
- the close listenerpublic ChannelListener<? super MessageConnection> getCloseListener()
CloseListenerSettable
getCloseListener
in interface CloseListenerSettable<MessageConnection>
public ChannelListener.Setter<MessageConnection> getCloseSetter()
CloseableChannel
getCloseSetter
in interface BoundChannel
getCloseSetter
in interface CloseableChannel
getCloseSetter
in interface ConnectedChannel
protected void setSourceConduit(MessageSourceConduit conduit)
protected void setSinkConduit(MessageSinkConduit conduit)
public ConduitReadableMessageChannel getSourceChannel()
public ConduitWritableMessageChannel getSinkChannel()
Copyright © 2021 JBoss by Red Hat. All rights reserved.