Class NatsMessageConsumer


  • public class NatsMessageConsumer
    extends Object
    Message consumer for NATS to initialize connection and listen for messages.
    • Constructor Detail

      • NatsMessageConsumer

        public NatsMessageConsumer​(Properties natsProperties,
                                   String inboundEndpointName)
    • Method Detail

      • initializeMessageListener

        public void initializeMessageListener()
        Initialize the message listener to use (Core NATS or NATS Streaming).
      • closeConnection

        public void closeConnection()
      • registerHandler

        public void registerHandler​(NatsInjectHandler injectHandler)
        Register a handler to implement injection of the retrieved message.
        Parameters:
        injectHandler - the injectHandler