public class RestWebSocket
extends java.lang.Object
| Modifier and Type | Field and Description |
|---|---|
protected java.util.Map<java.lang.String,jadex.commons.future.IFuture<?>> |
calls
The ongoing future calls.
|
| Constructor and Description |
|---|
RestWebSocket() |
| Modifier and Type | Method and Description |
|---|---|
protected jadex.commons.future.IFuture<jadex.bridge.IExternalAccess> |
getPlatform(javax.websocket.Session session)
Get or create the platform.
|
protected jadex.commons.future.IFuture<jadex.bridge.service.IService> |
getService(java.lang.String sid,
jadex.bridge.IExternalAccess platform)
Get a service via its sid.
|
protected jadex.commons.future.IFuture<jadex.bridge.service.IServiceIdentifier> |
getServiceIdentifier(java.lang.String sidname,
jadex.bridge.IExternalAccess platform)
Create a service identifier back from its string representation.
|
protected java.lang.Object[] |
getServiceInfo(jadex.bridge.service.IService service)
Get info for a service.
|
void |
onClose(javax.websocket.CloseReason reason,
javax.websocket.Session session) |
void |
onMessage(java.lang.String txt,
javax.websocket.Session session) |
void |
onOpen(javax.websocket.Session session,
javax.websocket.EndpointConfig config) |
protected jadex.commons.future.IFuture<java.lang.String> |
sendException(java.lang.Exception ex,
java.lang.String callid,
javax.websocket.Session session)
Send an exception message back to the client.
|
protected jadex.commons.future.IFuture<java.lang.String> |
sendMessage(ResultMessage rm,
javax.websocket.Session session)
Send an message back to the client.
|
protected jadex.commons.future.IFuture<java.lang.String> |
sendResult(java.lang.Object res,
java.lang.String callid,
javax.websocket.Session session,
boolean finished)
Send a result message back to the client.
|
protected java.util.Map<java.lang.String,jadex.commons.future.IFuture<?>> calls
public void onOpen(javax.websocket.Session session,
javax.websocket.EndpointConfig config)
public void onMessage(java.lang.String txt,
javax.websocket.Session session)
throws java.io.IOException
java.io.IOExceptionpublic void onClose(javax.websocket.CloseReason reason,
javax.websocket.Session session)
protected java.lang.Object[] getServiceInfo(jadex.bridge.service.IService service)
protected jadex.commons.future.IFuture<java.lang.String> sendResult(java.lang.Object res,
java.lang.String callid,
javax.websocket.Session session,
boolean finished)
protected jadex.commons.future.IFuture<java.lang.String> sendException(java.lang.Exception ex,
java.lang.String callid,
javax.websocket.Session session)
protected jadex.commons.future.IFuture<java.lang.String> sendMessage(ResultMessage rm, javax.websocket.Session session)
protected jadex.commons.future.IFuture<jadex.bridge.service.IServiceIdentifier> getServiceIdentifier(java.lang.String sidname,
jadex.bridge.IExternalAccess platform)
protected jadex.commons.future.IFuture<jadex.bridge.service.IService> getService(java.lang.String sid,
jadex.bridge.IExternalAccess platform)
protected jadex.commons.future.IFuture<jadex.bridge.IExternalAccess> getPlatform(javax.websocket.Session session)