Class NatsEndpointManager
- java.lang.Object
-
- org.wso2.carbon.inbound.endpoint.common.AbstractInboundEndpointManager
-
- org.wso2.carbon.inbound.endpoint.protocol.nats.management.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
-
-
Field Summary
-
Fields inherited from class org.wso2.carbon.inbound.endpoint.common.AbstractInboundEndpointManager
dataStore
-
-
Constructor Summary
Constructors Constructor Description NatsEndpointManager()
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description void
closeEndpoint(int port)
Stop Inbound Endpointstatic NatsEndpointManager
getInstance()
NatsMessageConsumer
getMessageConsumer()
boolean
startEndpoint(int port, String name, org.apache.synapse.inbound.InboundProcessorParams params)
Start NATS Inbound endpointboolean
startListener(int port, String name, org.apache.synapse.inbound.InboundProcessorParams inboundParameters)
Start NATS Listener-
Methods inherited from class org.wso2.carbon.inbound.endpoint.common.AbstractInboundEndpointManager
getEndpointName
-
-
-
-
Method Detail
-
getInstance
public static NatsEndpointManager getInstance()
-
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 nameinboundParameters
- 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 nameparams
- inbound endpoint params
-
closeEndpoint
public void closeEndpoint(int port)
Stop Inbound Endpoint- Parameters:
port
- port of the endpoint (not needed for NATS Inbound Endpoint)
-
getMessageConsumer
public NatsMessageConsumer getMessageConsumer()
-
-