Package com.qfs.msg

Interface IMessageHandler<I>

    • Method Detail

      • onMessageStarted

        void onMessageStarted​(I key)
        Called when the message starts.
        Parameters:
        key - the key of the message
      • onMessagePublished

        void onMessagePublished​(I key,
                                IPublicationInfo info)
        Called after the message has been successfully published.
        Parameters:
        key - the key of the message
        info - information about the publication of the message (optional, may be null if the data source does not support this feature)
      • onError

        void onError​(I key,
                     Throwable ex)
        The method that is called when there is an error.

        This method is supposed to gracefully handle the error without failure. Particularly, throwing in this method results in an undefined behaviour, including the unexpected stoppage of the channel processing.

        Parameters:
        key - the key of the message
        ex - the exception