org.wso2.carbon.inbound.endpoint.protocol.nats.management

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 and Description
NatsEndpointManager()

Method Summary

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

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 Detail

NatsEndpointManager

public NatsEndpointManager()

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

getMessageConsumer

public NatsMessageConsumer getMessageConsumer()