public class WebSocketServerConnection extends AbstractWebSocketConnection implements Connection.UpgradeTo
AbstractWebSocketConnection.OnCloseLocalCallback, AbstractWebSocketConnection.OnDisconnectCallback, AbstractWebSocketConnection.Stats
AbstractConnection.FillingInterestedCallback, AbstractConnection.NestedState, AbstractConnection.State
Connection.Listener, Connection.UpgradeFrom, Connection.UpgradeTo
EXECUTE_ONFILLABLE, FILL_INTERESTED, FILLING, FILLING_FILL_INTERESTED, IDLE, REFILLING
Constructor and Description |
---|
WebSocketServerConnection(EndPoint endp,
Executor executor,
Scheduler scheduler,
WebSocketPolicy policy,
ByteBufferPool bufferPool) |
Modifier and Type | Method and Description |
---|---|
InetSocketAddress |
getLocalAddress()
Get the local
InetSocketAddress in use for this connection. |
InetSocketAddress |
getRemoteAddress()
Get the remote Address in use for this connection.
|
void |
onOpen() |
void |
onUpgradeTo(ByteBuffer prefilled)
Callback method invoked when this
Connection is upgraded. |
void |
setNextIncomingFrames(IncomingFrames incoming)
Set where the connection should send the incoming frames to.
|
close, close, disconnect, dump, dump, execute, fillInterested, getBufferPool, getExecutor, getExtensions, getGenerator, getIdleTimeout, getIOState, getMaxIdleTimeout, getParser, getPolicy, getScheduler, getSession, getStats, isOpen, isReading, onClose, onConnectionStateChange, onFillable, onFillInterestedFailed, onReadTimeout, outgoingFrame, prefill, resume, setExtensions, setInputBufferSize, setMaxIdleTimeout, setSession, suspend, toString
addListener, failedCallback, fillInterested, getBytesIn, getBytesOut, getCreatedTimeStamp, getEndPoint, getInputBufferSize, getMessagesIn, getMessagesOut, next
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
addListener, close, getBytesIn, getBytesOut, getCreatedTimeStamp, getEndPoint, getMessagesIn, getMessagesOut, onClose
public WebSocketServerConnection(EndPoint endp, Executor executor, Scheduler scheduler, WebSocketPolicy policy, ByteBufferPool bufferPool)
public InetSocketAddress getLocalAddress()
LogicalConnection
InetSocketAddress
in use for this connection.
Note: Non-physical connections, like during the Mux extensions, or during unit testing can result in a InetSocketAddress on port 0 and/or on localhost.
getLocalAddress
in interface LogicalConnection
public InetSocketAddress getRemoteAddress()
LogicalConnection
Note: Non-physical connections, like during the Mux extensions, or during unit testing can result in a InetSocketAddress on port 0 and/or on localhost.
getRemoteAddress
in interface LogicalConnection
getRemoteAddress
in class AbstractWebSocketConnection
public void onUpgradeTo(ByteBuffer prefilled)
Connection.UpgradeTo
Callback method invoked when this Connection
is upgraded.
This must be called before Connection.onOpen()
.
onUpgradeTo
in interface Connection.UpgradeTo
public void onOpen()
onOpen
in interface Connection
onOpen
in class AbstractWebSocketConnection
public void setNextIncomingFrames(IncomingFrames incoming)
LogicalConnection
Often this is from the Parser to the start of the extension stack, and eventually on to the session.
setNextIncomingFrames
in interface LogicalConnection
incoming
- the incoming frames handlerCopyright © 1995-2017 Webtide. All Rights Reserved.