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

Class CoreListener

java.lang.Object

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

All Implemented Interfaces:

NatsMessageListener

public class CoreListener
extends Object
implements NatsMessageListener

Core listener class which uses core NATS connection to receive messages.

Constructor Summary

Constructors

Constructor	Description
CoreListener(String subject, NatsInjectHandler injectHandler, Properties natsProperties)

Method Summary

Modifier and Type	Method	Description
void	closeConnection()	Close the connection to NATS server and set connection to null.
boolean	createConnection()	Create the connection to the Core NATS server.
io.nats.client.Connection	getNatsConnection()	Create and return the Core NATS connection.
void	initializeConsumer(String sequenceName)	Consume the message received and inject into the sequence.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

CoreListener

public CoreListener(String subject,
 NatsInjectHandler injectHandler,
 Properties natsProperties)

Method Details

createConnection

public boolean createConnection()
                         throws IOException,
InterruptedException

Create the connection to the Core NATS server.

Specified by:

createConnection in interface NatsMessageListener

Returns:

boolean value whether connection is created.

Throws:

IOException

InterruptedException

getNatsConnection

public io.nats.client.Connection getNatsConnection()
                                            throws IOException,
InterruptedException

Create and return the Core NATS connection.

Returns:

the Core NATS connection.

Throws:

IOException

InterruptedException

initializeConsumer

public void initializeConsumer(String sequenceName)
                        throws IOException,
InterruptedException

Consume the message received and inject into the sequence.

Specified by:

initializeConsumer in interface NatsMessageListener

Parameters:

sequenceName - the sequence to inject the message to.

Throws:

IOException

InterruptedException

closeConnection

public void closeConnection()

Close the connection to NATS server and set connection to null.

Specified by:

closeConnection in interface NatsMessageListener