Class WebsocketConnectionFactory
- java.lang.Object
-
- org.wso2.carbon.websocket.transport.WebsocketConnectionFactory
-
public class WebsocketConnectionFactory extends Object
-
-
Constructor Summary
Constructors Constructor Description WebsocketConnectionFactory(org.apache.axis2.description.TransportOutDescription transportOut)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
addChannelHandler(String sourceIdentifier, String clientIdentifier, WebSocketClientHandler clientHandler)
WebSocketClientHandler
cacheNewConnection(URI uri, String sourceIdentifier, String dispatchSequence, String dispatchErrorSequence, String contentType, String wsSubprotocol, Map<String,Object> headers, org.apache.synapse.inbound.InboundResponseSender inboundResponseSender, String responseDispatchSequence, String responseErrorSequence)
WebSocketClientHandler
getChannelHandler(URI uri, String sourceIdentifier, boolean handshakePresent, String dispatchSequence, String dispatchErrorSequence, String contentType, String wsSubprotocol, boolean isConnectionTerminate, Map<String,Object> headers, org.apache.synapse.inbound.InboundResponseSender inboundResponseSender, String responseDispatchSequence, String responseErrorSequence)
WebSocketClientHandler
getChannelHandlerFromPool(String sourceIdentifier, String clientIdentifier)
String
getClientHandlerIdentifier(URI uri)
void
removeChannelHandler(String sourceIdentifier, String clientIdentifier)
-
-
-
Method Detail
-
getChannelHandler
public WebSocketClientHandler getChannelHandler(URI uri, String sourceIdentifier, boolean handshakePresent, String dispatchSequence, String dispatchErrorSequence, String contentType, String wsSubprotocol, boolean isConnectionTerminate, Map<String,Object> headers, org.apache.synapse.inbound.InboundResponseSender inboundResponseSender, String responseDispatchSequence, String responseErrorSequence) throws InterruptedException
- Throws:
InterruptedException
-
cacheNewConnection
public WebSocketClientHandler cacheNewConnection(URI uri, String sourceIdentifier, String dispatchSequence, String dispatchErrorSequence, String contentType, String wsSubprotocol, Map<String,Object> headers, org.apache.synapse.inbound.InboundResponseSender inboundResponseSender, String responseDispatchSequence, String responseErrorSequence)
-
addChannelHandler
public void addChannelHandler(String sourceIdentifier, String clientIdentifier, WebSocketClientHandler clientHandler)
-
getChannelHandlerFromPool
public WebSocketClientHandler getChannelHandlerFromPool(String sourceIdentifier, String clientIdentifier)
-
-