public class JsonRpcPeer
extends java.lang.Object
| Constructor and Description |
|---|
JsonRpcPeer(ObjectMapper objectMapper,
SimpleSession peer) |
| Modifier and Type | Method and Description |
|---|---|
PendingRequest |
getAndRemovePendingRequest(long requestId) |
SimpleSession |
getWebSocket() |
void |
invokeDisconnectReceivers() |
void |
invokeMethod(java.lang.String method,
java.lang.Object paramsObject,
PendingRequestCallback callback) |
void |
registerDisconnectReceiver(DisconnectReceiver callback) |
void |
unregisterDisconnectReceiver(DisconnectReceiver callback) |
public JsonRpcPeer(ObjectMapper objectMapper, SimpleSession peer)
public SimpleSession getWebSocket()
public void invokeMethod(java.lang.String method,
java.lang.Object paramsObject,
PendingRequestCallback callback)
throws java.nio.channels.NotYetConnectedException
java.nio.channels.NotYetConnectedExceptionpublic void registerDisconnectReceiver(DisconnectReceiver callback)
public void unregisterDisconnectReceiver(DisconnectReceiver callback)
public void invokeDisconnectReceivers()
public PendingRequest getAndRemovePendingRequest(long requestId)