org.wso2.carbon.device.mgt.output.adapter.websocket

Class WebsocketOutputCallbackControllerServiceImpl

java.lang.Object

org.wso2.carbon.device.mgt.output.adapter.websocket.WebsocketOutputCallbackControllerServiceImpl

All Implemented Interfaces:

WebsocketOutputCallbackControllerService

public class WebsocketOutputCallbackControllerServiceImpl
extends Object
implements WebsocketOutputCallbackControllerService

Service implementation class which exposes to front end

Constructor Summary

Constructors

Constructor and Description
WebsocketOutputCallbackControllerServiceImpl()

Method Summary

Methods

Modifier and Type	Method and Description
LinkedBlockingDeque<Object>	getEvents(int tenanId, String streamName, String version) Used to return events per streamId
CopyOnWriteArrayList<WebSocketSessionRequest>	getSessions(int tenantId, String streamId) Used to return registered sessions per streamId
void	subscribeWebsocket(String streamName, String version, javax.websocket.Session session) Used to subscribe the session id and stream id for later web socket connectivity
void	unsubscribeWebsocket(String streamName, String version, javax.websocket.Session session) Used to return events per streamId

Methods inherited from class java.lang.Object

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

Constructor Detail

WebsocketOutputCallbackControllerServiceImpl

public WebsocketOutputCallbackControllerServiceImpl()

Method Detail

subscribeWebsocket

public void subscribeWebsocket(String streamName,
                      String version,
                      javax.websocket.Session session)

Used to subscribe the session id and stream id for later web socket connectivity

Specified by:

subscribeWebsocket in interface WebsocketOutputCallbackControllerService

Parameters:

streamName - - Stream name which user register to.

version - - Stream version which user uses.

session - - Session which user registered.

getSessions

public CopyOnWriteArrayList<WebSocketSessionRequest> getSessions(int tenantId,
                                                        String streamId)

Used to return registered sessions per streamId

Parameters:

tenantId - - Tenant id of the user.

streamId - - Stream name and version which user register to.

Returns:

the sessions list.

getEvents

public LinkedBlockingDeque<Object> getEvents(int tenanId,
                                    String streamName,
                                    String version)

Used to return events per streamId

Parameters:

tenanId - - Tenant id of the user.

streamName - - Stream name which user register to.

version - - Stream version which user uses.

Returns:

the events list.

unsubscribeWebsocket

public void unsubscribeWebsocket(String streamName,
                        String version,
                        javax.websocket.Session session)

Used to return events per streamId

Specified by:

unsubscribeWebsocket in interface WebsocketOutputCallbackControllerService

Parameters:

streamName - - Stream name which user register to.

version - - Stream version which user uses.

session - - Session which user subscribed to.