org.glassfish.tyrus.core

Class RemoteEndpointWrapper

java.lang.Object

org.glassfish.tyrus.core.RemoteEndpointWrapper

All Implemented Interfaces:

javax.websocket.RemoteEndpoint

public abstract class RemoteEndpointWrapper
extends Object
implements javax.websocket.RemoteEndpoint

Wraps the RemoteEndpoint and represents the other side of the websocket connection.

Author:

Danny Coward (danny.coward at oracle.com), Martin Matula (martin.matula at oracle.com), Stepan Kopriva (stepan.kopriva at oracle.com), Pavel Bucek (pavel.bucek at oracle.com)

Field Summary

Fields

Modifier and Type	Field and Description
protected EndpointWrapper	endpointWrapper
protected SPIRemoteEndpoint	remoteEndpoint
protected SessionImpl	session

Method Summary

Methods

Modifier and Type	Method and Description
void	close(javax.websocket.CloseReason cr)
void	flushBatch()
boolean	getBatchingAllowed()
protected boolean	isPrimitiveData(Object data)
void	sendPing(ByteBuffer applicationData)
void	sendPong(ByteBuffer applicationData)
protected Future<?>	sendSyncBinary(ByteBuffer buf)
protected Future<?>	sendSyncObject(Object o)
protected Future<?>	sendSyncText(String data)
void	setBatchingAllowed(boolean allowed)
String	toString()

Methods inherited from class java.lang.Object

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

Field Detail

remoteEndpoint

protected final SPIRemoteEndpoint remoteEndpoint

session

protected final SessionImpl session

endpointWrapper

protected final EndpointWrapper endpointWrapper

Method Detail

sendSyncText

protected Future<?> sendSyncText(String data)
                          throws IOException

Throws:

IOException

sendSyncBinary

protected Future<?> sendSyncBinary(ByteBuffer buf)
                            throws IOException

Throws:

IOException

sendSyncObject

protected Future<?> sendSyncObject(Object o)
                            throws IOException,
                                   javax.websocket.EncodeException

Throws:

IOException

javax.websocket.EncodeException

isPrimitiveData

protected boolean isPrimitiveData(Object data)

sendPing

public void sendPing(ByteBuffer applicationData)
              throws IOException

Specified by:

sendPing in interface javax.websocket.RemoteEndpoint

Throws:

IOException

sendPong

public void sendPong(ByteBuffer applicationData)
              throws IOException

Specified by:

sendPong in interface javax.websocket.RemoteEndpoint

Throws:

IOException

toString

public String toString()

Overrides:

toString in class Object

setBatchingAllowed

public void setBatchingAllowed(boolean allowed)

Specified by:

setBatchingAllowed in interface javax.websocket.RemoteEndpoint

getBatchingAllowed

public boolean getBatchingAllowed()

Specified by:

getBatchingAllowed in interface javax.websocket.RemoteEndpoint

flushBatch

public void flushBatch()

Specified by:

flushBatch in interface javax.websocket.RemoteEndpoint

close

public void close(javax.websocket.CloseReason cr)