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

Class StreamingListener

java.lang.Object

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

All Implemented Interfaces:

NatsMessageListener

public class StreamingListener
extends Object
implements NatsMessageListener

Streaming listener class which uses NATS streaming connection to receive messages.

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
void	closeConnection()	Close the connection to NATS Streaming server and set connection to null.
boolean	createConnection()	Create the connection to the NATS Streaming server.
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

StreamingListener

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

Method Details

createConnection

public boolean createConnection()
                         throws IOException,
InterruptedException

Create the connection to the NATS Streaming server.

Specified by:

createConnection in interface NatsMessageListener

Returns:

boolean value whether connection is created.

Throws:

IOException

InterruptedException

initializeConsumer

public void initializeConsumer(String sequenceName)
                        throws InterruptedException,
IOException,
TimeoutException

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:

InterruptedException

IOException

TimeoutException

closeConnection

public void closeConnection()

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

Specified by:

closeConnection in interface NatsMessageListener