org.wso2.carbon.data.provider.websocket.endpoint

Class WebSocketProviderEndPoint

java.lang.Object

org.wso2.carbon.data.provider.websocket.endpoint.WebSocketProviderEndPoint

All Implemented Interfaces:

org.wso2.msf4j.websocket.WebSocketEndpoint

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

Constructor Summary

Constructors

Constructor and Description
WebSocketProviderEndPoint()

Method Summary

Modifier and Type	Method and Description
void	onClose(org.wso2.transport.http.netty.contract.websocket.WebSocketConnection webSocketConnection)
void	onError(Throwable throwable)
void	onMessage(String message, String topic)
static void	onOpen(org.wso2.transport.http.netty.contract.websocket.WebSocketConnection webSocketConnection, String topic)
static void	subscribeToTopic(String topic, WebSocketChannel channel)
static void	unsubscribeFromTopic(String topic, String sessionID)

Methods inherited from class java.lang.Object

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

Constructor Detail

WebSocketProviderEndPoint

public WebSocketProviderEndPoint()

Method Detail

onOpen

public static void onOpen(org.wso2.transport.http.netty.contract.websocket.WebSocketConnection webSocketConnection,
                          String topic)

onMessage

public void onMessage(String message,
                      String topic)

onClose

public void onClose(org.wso2.transport.http.netty.contract.websocket.WebSocketConnection webSocketConnection)

onError

public void onError(Throwable throwable)

subscribeToTopic

public static void subscribeToTopic(String topic,
                                    WebSocketChannel channel)

unsubscribeFromTopic

public static void unsubscribeFromTopic(String topic,
                                        String sessionID)