public class WebsocketConnectionFactory extends Object
Constructor and Description |
---|
WebsocketConnectionFactory(org.apache.axis2.description.TransportOutDescription transportOut) |
Modifier and Type | Method and 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) |
public WebsocketConnectionFactory(org.apache.axis2.description.TransportOutDescription transportOut) throws org.apache.axis2.AxisFault
org.apache.axis2.AxisFault
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
InterruptedException
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)
public void addChannelHandler(String sourceIdentifier, String clientIdentifier, WebSocketClientHandler clientHandler)
public WebSocketClientHandler getChannelHandlerFromPool(String sourceIdentifier, String clientIdentifier)
Copyright © 2022 WSO2. All rights reserved.