Package org.wso2.carbon.inbound.endpoint.protocol.websocket.management

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

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 Endpoint
static 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 port
boolean	startListener(int port, String name, org.apache.synapse.inbound.InboundProcessorParams params)	Start Listener on a particular port
boolean	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

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

WebsocketEndpointManager

protected WebsocketEndpointManager()

Method Details

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 - port

name - endpoint name

params - 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 - port

name - endpoint name

params - 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)