public class WebsocketOutputCallbackControllerServiceImpl extends Object implements WebsocketOutputCallbackControllerService
Constructor and Description |
---|
WebsocketOutputCallbackControllerServiceImpl() |
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
|
public WebsocketOutputCallbackControllerServiceImpl()
public void subscribeWebsocket(String streamName, String version, javax.websocket.Session session)
subscribeWebsocket
in interface WebsocketOutputCallbackControllerService
streamName
- - Stream name which user register to.version
- - Stream version which user uses.session
- - Session which user registered.public CopyOnWriteArrayList<WebSocketSessionRequest> getSessions(int tenantId, String streamId)
tenantId
- - Tenant id of the user.streamId
- - Stream name and version which user register to.public LinkedBlockingDeque<Object> getEvents(int tenanId, String streamName, String version)
tenanId
- - Tenant id of the user.streamName
- - Stream name which user register to.version
- - Stream version which user uses.public void unsubscribeWebsocket(String streamName, String version, javax.websocket.Session session)
unsubscribeWebsocket
in interface WebsocketOutputCallbackControllerService
streamName
- - Stream name which user register to.version
- - Stream version which user uses.session
- - Session which user subscribed to.Copyright © 2017 WSO2. All rights reserved.