Class AbstractJsrRemote
- java.lang.Object
-
- org.eclipse.jetty.websocket.jsr356.AbstractJsrRemote
-
- All Implemented Interfaces:
javax.websocket.RemoteEndpoint
- Direct Known Subclasses:
JsrAsyncRemote
,JsrBasicRemote
public abstract class AbstractJsrRemote extends java.lang.Object implements javax.websocket.RemoteEndpoint
-
-
Field Summary
Fields Modifier and Type Field Description protected EncoderFactory
encoders
protected WebSocketRemoteEndpoint
jettyRemote
protected JsrSession
session
-
Constructor Summary
Constructors Modifier Constructor Description protected
AbstractJsrRemote(JsrSession session)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected void
assertMessageNotNull(java.lang.Object data)
protected void
assertSendHandlerNotNull(javax.websocket.SendHandler handler)
void
flushBatch()
boolean
getBatchingAllowed()
java.util.concurrent.Future<java.lang.Void>
sendObjectViaFuture(java.lang.Object data)
void
sendPing(java.nio.ByteBuffer data)
void
sendPong(java.nio.ByteBuffer data)
void
setBatchingAllowed(boolean allowed)
-
-
-
Field Detail
-
session
protected final JsrSession session
-
jettyRemote
protected final WebSocketRemoteEndpoint jettyRemote
-
encoders
protected final EncoderFactory encoders
-
-
Constructor Detail
-
AbstractJsrRemote
protected AbstractJsrRemote(JsrSession session)
-
-
Method Detail
-
assertMessageNotNull
protected void assertMessageNotNull(java.lang.Object data)
-
assertSendHandlerNotNull
protected void assertSendHandlerNotNull(javax.websocket.SendHandler handler)
-
flushBatch
public void flushBatch() throws java.io.IOException
- Specified by:
flushBatch
in interfacejavax.websocket.RemoteEndpoint
- Throws:
java.io.IOException
-
getBatchingAllowed
public boolean getBatchingAllowed()
- Specified by:
getBatchingAllowed
in interfacejavax.websocket.RemoteEndpoint
-
setBatchingAllowed
public void setBatchingAllowed(boolean allowed) throws java.io.IOException
- Specified by:
setBatchingAllowed
in interfacejavax.websocket.RemoteEndpoint
- Throws:
java.io.IOException
-
sendObjectViaFuture
public java.util.concurrent.Future<java.lang.Void> sendObjectViaFuture(java.lang.Object data)
-
sendPing
public void sendPing(java.nio.ByteBuffer data) throws java.io.IOException, java.lang.IllegalArgumentException
- Specified by:
sendPing
in interfacejavax.websocket.RemoteEndpoint
- Throws:
java.io.IOException
java.lang.IllegalArgumentException
-
sendPong
public void sendPong(java.nio.ByteBuffer data) throws java.io.IOException, java.lang.IllegalArgumentException
- Specified by:
sendPong
in interfacejavax.websocket.RemoteEndpoint
- Throws:
java.io.IOException
java.lang.IllegalArgumentException
-
-