Class WebsocketEndpointManager
- java.lang.Object
-
- org.wso2.carbon.inbound.endpoint.common.AbstractInboundEndpointManager
-
- org.wso2.carbon.inbound.endpoint.protocol.websocket.management.WebsocketEndpointManager
-
- All Implemented Interfaces:
InboundEndpointManager
public class WebsocketEndpointManager extends AbstractInboundEndpointManager
-
-
Field Summary
-
Fields inherited from class org.wso2.carbon.inbound.endpoint.common.AbstractInboundEndpointManager
dataStore
-
-
Constructor Summary
Constructors Modifier Constructor Description protected
WebsocketEndpointManager()
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description void
broadcastShutDownToSubscriber(String endpointName, org.apache.synapse.inbound.InboundProcessorParams processorParams)
InboundWebsocketConfiguration
buildConfiguration(int port, String name, org.apache.synapse.inbound.InboundProcessorParams params)
InboundWebsocketSSLConfiguration
buildSSLConfiguration(org.apache.synapse.inbound.InboundProcessorParams params)
void
closeEndpoint(int port)
Stop Inbound Endpointstatic WebsocketEndpointManager
getInstance()
InboundWebsocketSourceHandler
getSourceHandler()
void
loadEndpointListeners()
void
setSourceHandler(InboundWebsocketSourceHandler sourceHandler)
boolean
startEndpoint(int port, String name, org.apache.synapse.inbound.InboundProcessorParams params)
Start Inbound endpoint on a particular portboolean
startListener(int port, String name, org.apache.synapse.inbound.InboundProcessorParams params)
Start Listener on a particular portboolean
startSSLEndpoint(int port, String name, org.apache.synapse.inbound.InboundProcessorParams params)
boolean
startSSLListener(int port, String name, org.apache.synapse.inbound.InboundProcessorParams params)
protected int
validateBroadcastLevelParam(String broadcastLevelParam)
-
Methods inherited from class org.wso2.carbon.inbound.endpoint.common.AbstractInboundEndpointManager
getEndpointName
-
-
-
-
Method Detail
-
getInstance
public static WebsocketEndpointManager getInstance()
-
startEndpoint
public boolean startEndpoint(int port, String name, org.apache.synapse.inbound.InboundProcessorParams params)
Description copied from interface:InboundEndpointManager
Start Inbound endpoint on a particular port- Parameters:
port
- portname
- endpoint nameparams
- Inbound endpoint parameters
-
startSSLEndpoint
public boolean startSSLEndpoint(int port, String name, org.apache.synapse.inbound.InboundProcessorParams params)
-
startListener
public boolean startListener(int port, String name, org.apache.synapse.inbound.InboundProcessorParams params)
Description copied from interface:InboundEndpointManager
Start Listener on a particular port- Parameters:
port
- portname
- endpoint nameparams
- Inbound endpoint parameters
-
startSSLListener
public boolean startSSLListener(int port, String name, org.apache.synapse.inbound.InboundProcessorParams params)
-
broadcastShutDownToSubscriber
public void broadcastShutDownToSubscriber(String endpointName, org.apache.synapse.inbound.InboundProcessorParams processorParams)
-
closeEndpoint
public void closeEndpoint(int port)
Description copied from interface:InboundEndpointManager
Stop Inbound Endpoint- Parameters:
port
- port of the endpoint
-
buildConfiguration
public InboundWebsocketConfiguration buildConfiguration(int port, String name, org.apache.synapse.inbound.InboundProcessorParams params)
-
validateBroadcastLevelParam
protected int validateBroadcastLevelParam(String broadcastLevelParam)
-
buildSSLConfiguration
public InboundWebsocketSSLConfiguration buildSSLConfiguration(org.apache.synapse.inbound.InboundProcessorParams params)
-
loadEndpointListeners
public void loadEndpointListeners()
-
getSourceHandler
public InboundWebsocketSourceHandler getSourceHandler()
-
setSourceHandler
public void setSourceHandler(InboundWebsocketSourceHandler sourceHandler)
-
-