public class NatsEndpointManager extends AbstractInboundEndpointManager
dataStore
Constructor and Description |
---|
NatsEndpointManager() |
Modifier and Type | Method and Description |
---|---|
void |
closeEndpoint(int port)
Stop Inbound Endpoint
|
static NatsEndpointManager |
getInstance() |
NatsMessageConsumer |
getMessageConsumer() |
boolean |
startEndpoint(int port,
String name,
org.apache.synapse.inbound.InboundProcessorParams params)
Start NATS Inbound endpoint
|
boolean |
startListener(int port,
String name,
org.apache.synapse.inbound.InboundProcessorParams inboundParameters)
Start NATS Listener
|
getEndpointName
public static NatsEndpointManager getInstance()
public boolean startListener(int port, String name, org.apache.synapse.inbound.InboundProcessorParams inboundParameters)
port
- port (not needed for NATS Inbound Endpoint)name
- endpoint nameinboundParameters
- inbound endpoint paramspublic boolean startEndpoint(int port, String name, org.apache.synapse.inbound.InboundProcessorParams params)
port
- port (not needed for NATS Inbound Endpoint)name
- endpoint nameparams
- inbound endpoint paramspublic void closeEndpoint(int port)
port
- port of the endpoint (not needed for NATS Inbound Endpoint)public NatsMessageConsumer getMessageConsumer()
Copyright © 2020 WSO2. All rights reserved.