NatsMessageListener (org.wso2.carbon.inbound.endpoint 4.8.2 API)

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

Description

void

closeConnection()

boolean

createConnection()

void

initializeConsumer(String sequenceName)

Method Details
- 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()