public abstract class ServerSession
extends org.kurento.jsonrpc.internal.client.AbstractSession
Modifier and Type | Field and Description |
---|---|
static String |
SESSION_RECONNECTION_TIME_PROP |
Constructor and Description |
---|
ServerSession(String sessionId,
Object registerInfo,
SessionsManager sessionsManager,
String transportId) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
abstract void |
closeNativeSession(String reason) |
Map<String,Object> |
getAttributes() |
ScheduledFuture<?> |
getCloseTimerTask() |
long |
getReconnectionTimeoutInMillis() |
String |
getTransportId() |
abstract void |
handleResponse(org.kurento.jsonrpc.message.Response<com.google.gson.JsonElement> response) |
boolean |
isGracefullyClosed() |
void |
processRequest(Runnable task) |
void |
sendNotification(String method) |
void |
sendNotification(String method,
Object params) |
void |
sendNotification(String method,
Object params,
org.kurento.jsonrpc.client.Continuation<com.google.gson.JsonElement> continuation) |
org.kurento.jsonrpc.message.Response<com.google.gson.JsonElement> |
sendRequest(org.kurento.jsonrpc.message.Request<com.google.gson.JsonObject> request) |
void |
sendRequest(org.kurento.jsonrpc.message.Request<com.google.gson.JsonObject> request,
org.kurento.jsonrpc.client.Continuation<org.kurento.jsonrpc.message.Response<com.google.gson.JsonElement>> continuation) |
com.google.gson.JsonElement |
sendRequest(String method) |
<R> R |
sendRequest(String method,
Class<R> resultClass) |
void |
sendRequest(String method,
com.google.gson.JsonObject params,
org.kurento.jsonrpc.client.Continuation<com.google.gson.JsonElement> continuation) |
com.google.gson.JsonElement |
sendRequest(String method,
Object params) |
<R> R |
sendRequest(String method,
Object params,
Class<R> resultClass) |
org.kurento.jsonrpc.message.Response<com.google.gson.JsonElement> |
sendRequestHonorId(org.kurento.jsonrpc.message.Request<com.google.gson.JsonObject> request) |
void |
sendRequestHonorId(org.kurento.jsonrpc.message.Request<com.google.gson.JsonObject> request,
org.kurento.jsonrpc.client.Continuation<org.kurento.jsonrpc.message.Response<com.google.gson.JsonElement>> continuation) |
void |
setCloseTimerTask(ScheduledFuture<?> closeTimerTask) |
void |
setGracefullyClosed() |
void |
setReconnectionTimeout(long reconnectionTimeoutInMillis) |
protected void |
setRsHelper(org.kurento.jsonrpc.internal.JsonRpcRequestSenderHelper rsHelper) |
void |
setTransportId(String transportId) |
public static final String SESSION_RECONNECTION_TIME_PROP
public ServerSession(String sessionId, Object registerInfo, SessionsManager sessionsManager, String transportId)
public abstract void handleResponse(org.kurento.jsonrpc.message.Response<com.google.gson.JsonElement> response)
public String getTransportId()
public void setTransportId(String transportId)
public void close() throws IOException
IOException
protected void setRsHelper(org.kurento.jsonrpc.internal.JsonRpcRequestSenderHelper rsHelper)
public <R> R sendRequest(String method, Class<R> resultClass) throws IOException
IOException
public <R> R sendRequest(String method, Object params, Class<R> resultClass) throws IOException
IOException
public com.google.gson.JsonElement sendRequest(String method) throws IOException
IOException
public com.google.gson.JsonElement sendRequest(String method, Object params) throws IOException
IOException
public void sendRequest(String method, com.google.gson.JsonObject params, org.kurento.jsonrpc.client.Continuation<com.google.gson.JsonElement> continuation)
public void sendNotification(String method, Object params, org.kurento.jsonrpc.client.Continuation<com.google.gson.JsonElement> continuation) throws IOException
IOException
public void sendNotification(String method, Object params) throws IOException
IOException
public void sendNotification(String method) throws IOException
IOException
public org.kurento.jsonrpc.message.Response<com.google.gson.JsonElement> sendRequest(org.kurento.jsonrpc.message.Request<com.google.gson.JsonObject> request) throws IOException
IOException
public void sendRequest(org.kurento.jsonrpc.message.Request<com.google.gson.JsonObject> request, org.kurento.jsonrpc.client.Continuation<org.kurento.jsonrpc.message.Response<com.google.gson.JsonElement>> continuation) throws IOException
IOException
public void sendRequestHonorId(org.kurento.jsonrpc.message.Request<com.google.gson.JsonObject> request, org.kurento.jsonrpc.client.Continuation<org.kurento.jsonrpc.message.Response<com.google.gson.JsonElement>> continuation) throws IOException
IOException
public org.kurento.jsonrpc.message.Response<com.google.gson.JsonElement> sendRequestHonorId(org.kurento.jsonrpc.message.Request<com.google.gson.JsonObject> request) throws IOException
IOException
public void setCloseTimerTask(ScheduledFuture<?> closeTimerTask)
public void setGracefullyClosed()
public boolean isGracefullyClosed()
public ScheduledFuture<?> getCloseTimerTask()
public void setReconnectionTimeout(long reconnectionTimeoutInMillis)
public long getReconnectionTimeoutInMillis()
public abstract void closeNativeSession(String reason)
public void processRequest(Runnable task)
Copyright © 2017 Kurento. All rights reserved.