Class JakartaWebSocketRemoteEndpoint

java.lang.Object

org.eclipse.jetty.ee9.websocket.jakarta.common.JakartaWebSocketRemoteEndpoint

All Implemented Interfaces:

jakarta.websocket.RemoteEndpoint, OutgoingFrames

Direct Known Subclasses:

JakartaWebSocketAsyncRemote, JakartaWebSocketBasicRemote

public class JakartaWebSocketRemoteEndpoint
extends Object
implements jakarta.websocket.RemoteEndpoint, OutgoingFrames

Nested Class Summary

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

jakarta.websocket.RemoteEndpoint.Async, jakarta.websocket.RemoteEndpoint.Basic

Field Summary

Fields

Modifier and Type	Field	Description
protected boolean	batch
protected byte	messageType
protected long	messageWriteTimeout
protected final JakartaWebSocketSession	session

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	JakartaWebSocketRemoteEndpoint(JakartaWebSocketSession session, CoreSession coreSession)

Method Summary

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

Methods inherited from class Object

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

Field Details

session

protected final JakartaWebSocketSession session

batch

protected boolean batch

messageType

protected byte messageType

messageWriteTimeout

protected long messageWriteTimeout

Constructor Details

JakartaWebSocketRemoteEndpoint

protected JakartaWebSocketRemoteEndpoint(JakartaWebSocketSession session,
 CoreSession coreSession)

Method Details

newMessageWriter

protected MessageWriter newMessageWriter()

newMessageOutputStream

protected MessageOutputStream newMessageOutputStream()

flushBatch

public void flushBatch()
                throws IOException

Specified by:

flushBatch in interface jakarta.websocket.RemoteEndpoint

Throws:

IOException

getBatchingAllowed

public boolean getBatchingAllowed()

Specified by:

getBatchingAllowed in interface jakarta.websocket.RemoteEndpoint

setBatchingAllowed

public void setBatchingAllowed(boolean allowed)
                        throws IOException

Specified by:

setBatchingAllowed in interface jakarta.websocket.RemoteEndpoint

Throws:

IOException

getIdleTimeout

public long getIdleTimeout()

setIdleTimeout

public void setIdleTimeout(long ms)

sendFrame

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

Description copied from interface: OutgoingFrames

A frame, 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.

sendFrame

public void sendFrame(OutgoingEntry entry)

Description copied from interface: OutgoingFrames

Send an OutgoingEntry containing a Frame and Callback.

Specified by:

sendFrame in interface OutgoingFrames

Parameters:

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

sendObject

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

Throws:

IOException

jakarta.websocket.EncodeException

sendPing

public void sendPing(ByteBuffer data)
              throws IOException,
IllegalArgumentException

Specified by:

sendPing in interface jakarta.websocket.RemoteEndpoint

Throws:

IOException

IllegalArgumentException

sendPong

public void sendPong(ByteBuffer data)
              throws IOException,
IllegalArgumentException

Specified by:

sendPong in interface jakarta.websocket.RemoteEndpoint

Throws:

IOException

IllegalArgumentException

assertMessageNotNull

protected void assertMessageNotNull(Object data)

assertSendHandlerNotNull

protected void assertSendHandlerNotNull(jakarta.websocket.SendHandler handler)