Class JavaxWebSocketRemoteEndpoint

java.lang.Object

org.eclipse.jetty.ee8.websocket.javax.common.JavaxWebSocketRemoteEndpoint

All Implemented Interfaces:

javax.websocket.RemoteEndpoint, OutgoingFrames

Direct Known Subclasses:

JavaxWebSocketAsyncRemote, JavaxWebSocketBasicRemote

public class JavaxWebSocketRemoteEndpoint
extends Object
implements javax.websocket.RemoteEndpoint, OutgoingFrames

Nested Class Summary

Nested classes/interfaces inherited from interface javax.websocket.RemoteEndpoint

javax.websocket.RemoteEndpoint.Async, javax.websocket.RemoteEndpoint.Basic

Field Summary

Fields

Modifier and Type	Field	Description
protected boolean	batch
protected byte	messageType
protected final JavaxWebSocketSession	session

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	JavaxWebSocketRemoteEndpoint(JavaxWebSocketSession session, CoreSession coreSession)

Method Summary

Modifier and Type	Method	Description
protected void	assertMessageNotNull(Object data)
protected void	assertSendHandlerNotNull(javax.websocket.SendHandler handler)
void	flushBatch()
boolean	getBatchingAllowed()
long	getIdleTimeout()
long	getWriteTimeout()
protected MessageOutputStream	newMessageOutputStream()
protected MessageWriter	newMessageWriter()
void	sendFrame(Frame frame, Callback callback, boolean batch)	A frame, and optional callback, intended for the network layer.
void	sendObject(Object data, Callback callback)
void	sendPing(ByteBuffer data)
void	sendPong(ByteBuffer data)
void	setBatchingAllowed(boolean allowed)
void	setIdleTimeout(long ms)
void	setWriteTimeout(long ms)

Methods inherited from class Object

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

Field Details

session

protected final JavaxWebSocketSession session

batch

protected boolean batch

messageType

protected byte messageType

Constructor Details

JavaxWebSocketRemoteEndpoint

protected JavaxWebSocketRemoteEndpoint(JavaxWebSocketSession session,
 CoreSession coreSession)

Method Details

newMessageWriter

protected MessageWriter newMessageWriter()

newMessageOutputStream

protected MessageOutputStream newMessageOutputStream()

flushBatch

public void flushBatch()
                throws IOException

Specified by:

flushBatch in interface javax.websocket.RemoteEndpoint

Throws:

IOException

getBatchingAllowed

public boolean getBatchingAllowed()

Specified by:

getBatchingAllowed in interface javax.websocket.RemoteEndpoint

setBatchingAllowed

public void setBatchingAllowed(boolean allowed)
                        throws IOException

Specified by:

setBatchingAllowed in interface javax.websocket.RemoteEndpoint

Throws:

IOException

getIdleTimeout

public long getIdleTimeout()

setIdleTimeout

public void setIdleTimeout(long ms)

getWriteTimeout

public long getWriteTimeout()

setWriteTimeout

public void setWriteTimeout(long ms)

sendFrame

public void sendFrame(Frame frame,
 Callback callback,
 boolean batch)

Description copied from interface: OutgoingFrames

A frame, and optional callback, intended for the network layer.

Note: the frame can undergo many transformations in the various layers and extensions present in the implementation.

If you are implementing a mutation, you are obliged to handle the incoming Callback appropriately.

Specified by:

sendFrame in interface OutgoingFrames

Parameters:

frame - the frame to eventually write to the network layer.

callback - the callback to notify when the frame is written.

batch - the batch mode requested by the sender.

sendObject

public void sendObject(Object data,
 Callback callback)
                throws IOException,
javax.websocket.EncodeException

Throws:

IOException

javax.websocket.EncodeException

sendPing

public void sendPing(ByteBuffer data)
              throws IOException,
IllegalArgumentException

Specified by:

sendPing in interface javax.websocket.RemoteEndpoint

Throws:

IOException

IllegalArgumentException

sendPong

public void sendPong(ByteBuffer data)
              throws IOException,
IllegalArgumentException

Specified by:

sendPong in interface javax.websocket.RemoteEndpoint

Throws:

IOException

IllegalArgumentException

assertMessageNotNull

protected void assertMessageNotNull(Object data)

assertSendHandlerNotNull

protected void assertSendHandlerNotNull(javax.websocket.SendHandler handler)