Class NatsEndpointManager

  • All Implemented Interfaces:
    InboundEndpointManager

    public class NatsEndpointManager
    extends AbstractInboundEndpointManager
    Manager which handles NATS Listeners activities for Inbound Endpoints. This is the central place to mange Http Listeners for Inbound endpoints
    • Constructor Detail

      • NatsEndpointManager

        public NatsEndpointManager()
    • Method Detail

      • startListener

        public boolean startListener​(int port,
                                     String name,
                                     org.apache.synapse.inbound.InboundProcessorParams inboundParameters)
        Start NATS Listener
        Parameters:
        port - port (not needed for NATS Inbound Endpoint)
        name - endpoint name
        inboundParameters - inbound endpoint params
      • startEndpoint

        public boolean startEndpoint​(int port,
                                     String name,
                                     org.apache.synapse.inbound.InboundProcessorParams params)
        Start NATS Inbound endpoint
        Parameters:
        port - port (not needed for NATS Inbound Endpoint)
        name - endpoint name
        params - inbound endpoint params
      • closeEndpoint

        public void closeEndpoint​(int port)
        Stop Inbound Endpoint
        Parameters:
        port - port of the endpoint (not needed for NATS Inbound Endpoint)