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(String tenantDomain, 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, String correlationId, Map<String,Object> apiProperties)
WebSocketClientHandler
getChannelHandler(String tenantDomain, 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, String correlationId, Map<String,Object> apiProperties)
WebSocketClientHandler
getChannelHandlerFromPool(String sourceIdentifier, String clientIdentifier)
String
getClientHandlerIdentifier(URI uri)
void
removeChannelHandler(String sourceIdentifier, String clientIdentifier)
-
-
-
Method Detail
-
getChannelHandler
public WebSocketClientHandler getChannelHandler(String tenantDomain, 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, String correlationId, Map<String,Object> apiProperties) throws InterruptedException
- Throws:
InterruptedException
-
cacheNewConnection
public WebSocketClientHandler cacheNewConnection(String tenantDomain, 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, String correlationId, Map<String,Object> apiProperties)
-
addChannelHandler
public void addChannelHandler(String sourceIdentifier, String clientIdentifier, WebSocketClientHandler clientHandler)
-
getChannelHandlerFromPool
public WebSocketClientHandler getChannelHandlerFromPool(String sourceIdentifier, String clientIdentifier)
-
-