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

Interface NatsMessageListener

All Known Implementing Classes:

CoreListener, StreamingListener

public interface NatsMessageListener

The interface which defines behaviour of a core NATS or NATS streaming connection.

Method Summary

Modifier and Type	Method and Description
void	closeConnection()
boolean	createConnection()
void	initializeConsumer(String sequenceName)

Method Detail

createConnection

boolean createConnection()
                  throws IOException,
                         InterruptedException

Throws:

IOException

InterruptedException

initializeConsumer

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

Throws:

InterruptedException

IOException

TimeoutException

closeConnection

void closeConnection()