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
void	onClose(javax.websocket.Session session) handle disconnection with the client.
void	onError(Throwable throwable) handle on error.
void	onMessage(String message, String sourceType, javax.websocket.Session session) Create DataProvider instance, start it and store it in the providerMap.
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 text, String sessionId) 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 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,
                      String sourceType,
                      javax.websocket.Session session)

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

Parameters:

message - String message received from the web client

sourceType - datasource type from the Path parameter

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 text,
                            String sessionId)
                     throws IOException

Send message to specific client.

Parameters:

text - String message to be sent to the client

sessionId - String session id of the session

Throws:

IOException - If there is a problem delivering the message