Class WebsocketEndpointManager

    • Constructor Detail

      • WebsocketEndpointManager

        protected WebsocketEndpointManager()
    • Method Detail

      • 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
      • validateBroadcastLevelParam

        protected int validateBroadcastLevelParam​(String broadcastLevelParam)
      • loadEndpointListeners

        public void loadEndpointListeners()