Interface IMessageHandler

    • Method Detail

      • onMessageAsync

        CompletableFuture<Void> onMessageAsync​(IMessage message)
        The callback for message pump to pass received Messages.
        Parameters:
        message - The received Message.
        Returns:
        CompletableFuture for the message handler.
      • notifyException

        void notifyException​(Throwable exception,
                             ExceptionPhase phase)
        Receiving the exceptions that passed by pump during message processing.
        Parameters:
        exception - Exception received in pump.
        phase - Exception phase.