Class MessageReceiver

    • Method Detail

      • startup

        public void startup()
      • shutdown

        public void shutdown()
      • receiveMessage

        public void receiveMessage​(InboundMessageState state)
        This queues the message for processing. Processing will call state.releaseResources(), do not access state after calling this. BLOCKING if queue is full.