public class WebSocketDispatcher extends Object
WebSocketDispatcher
This is the web socket request dispatcher implementation which finds best matching
resource for incoming web socket request.Constructor and Description |
---|
WebSocketDispatcher() |
Modifier and Type | Method and Description |
---|---|
static void |
dispatchBinaryMessage(WebSocketOpenConnectionInfo connectionInfo,
org.wso2.transport.http.netty.contract.websocket.WebSocketBinaryMessage binaryMessage) |
static void |
dispatchCloseMessage(WebSocketOpenConnectionInfo connectionInfo,
org.wso2.transport.http.netty.contract.websocket.WebSocketCloseMessage closeMessage) |
static void |
dispatchControlMessage(WebSocketOpenConnectionInfo connectionInfo,
org.wso2.transport.http.netty.contract.websocket.WebSocketControlMessage controlMessage) |
static void |
dispatchIdleTimeout(WebSocketOpenConnectionInfo connectionInfo,
org.wso2.transport.http.netty.contract.websocket.WebSocketControlMessage controlMessage) |
static void |
dispatchTextMessage(WebSocketOpenConnectionInfo connectionInfo,
org.wso2.transport.http.netty.contract.websocket.WebSocketTextMessage textMessage) |
static WebSocketService |
findService(WebSocketServicesRegistry servicesRegistry,
Map<String,String> pathParams,
org.wso2.transport.http.netty.contract.websocket.WebSocketMessage webSocketMessage,
org.wso2.transport.http.netty.message.HTTPCarbonMessage msg)
This will find the best matching service for given web socket request.
|
static void |
setPathParams(BValue[] bValues,
List<ParamDetail> paramDetails,
Map<String,String> pathParams,
int defaultArgSize) |
public static WebSocketService findService(WebSocketServicesRegistry servicesRegistry, Map<String,String> pathParams, org.wso2.transport.http.netty.contract.websocket.WebSocketMessage webSocketMessage, org.wso2.transport.http.netty.message.HTTPCarbonMessage msg)
webSocketMessage
- incoming message.public static void dispatchTextMessage(WebSocketOpenConnectionInfo connectionInfo, org.wso2.transport.http.netty.contract.websocket.WebSocketTextMessage textMessage)
public static void dispatchBinaryMessage(WebSocketOpenConnectionInfo connectionInfo, org.wso2.transport.http.netty.contract.websocket.WebSocketBinaryMessage binaryMessage)
public static void dispatchControlMessage(WebSocketOpenConnectionInfo connectionInfo, org.wso2.transport.http.netty.contract.websocket.WebSocketControlMessage controlMessage)
public static void dispatchCloseMessage(WebSocketOpenConnectionInfo connectionInfo, org.wso2.transport.http.netty.contract.websocket.WebSocketCloseMessage closeMessage)
public static void dispatchIdleTimeout(WebSocketOpenConnectionInfo connectionInfo, org.wso2.transport.http.netty.contract.websocket.WebSocketControlMessage controlMessage)
Copyright © 2018 WSO2. All rights reserved.