org.eclipse.jetty.websocket.client.internal.io

Class WebSocketClientConnection

java.lang.Object

org.eclipse.jetty.io.AbstractConnection

org.eclipse.jetty.websocket.common.io.AbstractWebSocketConnection

org.eclipse.jetty.websocket.client.internal.io.WebSocketClientConnection

All Implemented Interfaces:

AutoCloseable, Connection, OutgoingFrames, SuspendToken, LogicalConnection

public class WebSocketClientConnection
extends AbstractWebSocketConnection

Client side WebSocket physical connection.

Nested Class Summary

Nested classes/interfaces inherited from interface org.eclipse.jetty.io.Connection

Connection.Listener

Constructor Summary

Constructors

Constructor and Description
WebSocketClientConnection(EndPoint endp, Executor executor, DefaultWebSocketClient client)

Method Summary

Methods

Modifier and Type	Method and Description
DefaultWebSocketClient	getClient()
InetSocketAddress	getLocalAddress() Get the local InetSocketAddress in use for this connection.
InetSocketAddress	getRemoteAddress() Get the remote Address in use for this connection.
void	onClose() Callback method invoked when this Connection is closed.
void	onOpen() Callback method invoked when this Connection is opened.
Future<javax.net.websocket.SendResult>	outgoingFrame(Frame frame)
void	setNextIncomingFrames(IncomingFrames incoming) Set where the connection should send the incoming frames to.

Methods inherited from class org.eclipse.jetty.websocket.common.io.AbstractWebSocketConnection

assertInputOpen, assertOutputOpen, close, close, complete, disconnect, disconnect, flush, getBufferPool, getExtensions, getGenerator, getParser, getPolicy, getQueue, getScheduler, getSession, getState, isInputClosed, isOpen, isOutputClosed, isReading, onCloseHandshake, onFillable, onReadTimeout, resume, setExtensions, setSession, suspend, toString

Methods inherited from class org.eclipse.jetty.io.AbstractConnection

addListener, fillInterested, getBytesIn, getBytesOut, getCreatedTimeStamp, getEndPoint, getExecutor, getInputBufferSize, getMessagesIn, getMessagesOut, onFillInterestedFailed, setInputBufferSize

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

WebSocketClientConnection

public WebSocketClientConnection(EndPoint endp,
                         Executor executor,
                         DefaultWebSocketClient client)

Method Detail

getClient

public DefaultWebSocketClient getClient()

getLocalAddress

public InetSocketAddress getLocalAddress()

Description copied from interface: LogicalConnection

Get the local 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.

Returns:

the local address.

getRemoteAddress

public InetSocketAddress getRemoteAddress()

Description copied from interface: LogicalConnection

Get the remote Address 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.

Specified by:

getRemoteAddress in interface LogicalConnection

Overrides:

getRemoteAddress in class AbstractWebSocketConnection

Returns:

the remote address.

onClose

public void onClose()

Description copied from interface: Connection

Callback method invoked when this Connection is closed.

Creators of the connection implementation are responsible for calling this method.

Specified by:

onClose in interface Connection

Overrides:

onClose in class AbstractWebSocketConnection

onOpen

public void onOpen()

Description copied from interface: Connection

Callback method invoked when this Connection is opened.

Creators of the connection implementation are responsible for calling this method.

Specified by:

onOpen in interface Connection

Overrides:

onOpen in class AbstractWebSocketConnection

outgoingFrame

public Future<javax.net.websocket.SendResult> outgoingFrame(Frame frame)
                                                     throws IOException

Specified by:

outgoingFrame in interface OutgoingFrames

Overrides:

outgoingFrame in class AbstractWebSocketConnection

Throws:

IOException

setNextIncomingFrames

public void setNextIncomingFrames(IncomingFrames incoming)

Description copied from interface: LogicalConnection

Set where the connection should send the incoming frames to.

Often this is from the Parser to the start of the extension stack, and eventually on to the session.

Parameters:

incoming - the incoming frames handler