public abstract class AbstractJsrRemote extends Object implements RemoteEndpoint
RemoteEndpoint.Async, RemoteEndpoint.Basic| Modifier and Type | Field and Description |
|---|---|
protected EncoderFactory |
encoders |
protected WebSocketRemoteEndpoint |
jettyRemote |
protected JsrSession |
session |
| Modifier | Constructor and Description |
|---|---|
protected |
AbstractJsrRemote(JsrSession session) |
| Modifier and Type | Method and Description |
|---|---|
protected void |
assertMessageNotNull(Object data) |
protected void |
assertSendHandlerNotNull(SendHandler handler) |
void |
flushBatch() |
boolean |
getBatchingAllowed() |
Future<Void> |
sendObjectViaFuture(Object data) |
void |
sendPing(ByteBuffer data) |
void |
sendPong(ByteBuffer data) |
void |
setBatchingAllowed(boolean allowed) |
protected final JsrSession session
protected final WebSocketRemoteEndpoint jettyRemote
protected final EncoderFactory encoders
protected AbstractJsrRemote(JsrSession session)
protected void assertMessageNotNull(Object data)
protected void assertSendHandlerNotNull(SendHandler handler)
public void flushBatch()
throws IOException
flushBatch in interface RemoteEndpointIOExceptionpublic boolean getBatchingAllowed()
getBatchingAllowed in interface RemoteEndpointpublic void setBatchingAllowed(boolean allowed)
throws IOException
setBatchingAllowed in interface RemoteEndpointIOExceptionpublic void sendPing(ByteBuffer data) throws IOException, IllegalArgumentException
sendPing in interface RemoteEndpointIOExceptionIllegalArgumentExceptionpublic void sendPong(ByteBuffer data) throws IOException, IllegalArgumentException
sendPong in interface RemoteEndpointIOExceptionIllegalArgumentExceptionCopyright © 1995-2015 Webtide. All Rights Reserved.