org.wso2.carbon.data.provider.endpoint

Class DataProviderEndPoint

java.lang.Object

org.wso2.carbon.data.provider.endpoint.DataProviderEndPoint

All Implemented Interfaces:

org.wso2.msf4j.websocket.WebSocketEndpoint

public class DataProviderEndPoint
extends Object
implements org.wso2.msf4j.websocket.WebSocketEndpoint

Data provider web socket endpoint.

Constructor Summary

Constructors

Constructor and Description
DataProviderEndPoint()

Method Summary

Modifier and Type	Method and Description
static Map<String,javax.websocket.Session>	getSessionMap()
void	onClose(javax.websocket.Session session) handle disconnection with the client.
void	onError(Throwable throwable) handle on error.
void	onMessage(String message, javax.websocket.Session session) Create DataProvider instance, start it and store it in the providerMap.
static void	onOpen(javax.websocket.Session session) Handle initiation of the connection map the session object in the session map.
protected void	registerDataSourceService(org.wso2.carbon.datasource.core.api.DataSourceService service)
static void	sendText(String sessionId, String text) Send message to specific client.
protected void	setConfigProvider(org.wso2.carbon.config.provider.ConfigProvider configProvider)
protected void	unregisterDataSourceService(org.wso2.carbon.datasource.core.api.DataSourceService service)
protected void	unsetConfigProvider(org.wso2.carbon.config.provider.ConfigProvider configProvider)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

DataProviderEndPoint

public DataProviderEndPoint()

Method Detail

registerDataSourceService

protected void registerDataSourceService(org.wso2.carbon.datasource.core.api.DataSourceService service)

unregisterDataSourceService

protected void unregisterDataSourceService(org.wso2.carbon.datasource.core.api.DataSourceService service)

setConfigProvider

protected void setConfigProvider(org.wso2.carbon.config.provider.ConfigProvider configProvider)

unsetConfigProvider

protected void unsetConfigProvider(org.wso2.carbon.config.provider.ConfigProvider configProvider)

onOpen

public static void onOpen(javax.websocket.Session session)

Handle initiation of the connection map the session object in the session map.

Parameters:

session - Session object associated with the connection

onMessage

public void onMessage(String message,
                      javax.websocket.Session session)

Create DataProvider instance, start it and store it in the providerMap.

Parameters:

message - String message received from the web client

session - Session object associated with the connection

onClose

public void onClose(javax.websocket.Session session)

handle disconnection with the client.

Parameters:

session - Session object associated with the connection

onError

public void onError(Throwable throwable)

handle on error.

sendText

public static void sendText(String sessionId,
                            String text)
                     throws IOException

Send message to specific client.

Parameters:

sessionId - sessionId of the client.

text - String message to be sent to the client.

Throws:

IOException - If there is a problem delivering the message.

getSessionMap

public static Map<String,javax.websocket.Session> getSessionMap()