Interface MessageListener<M>

    • Method Detail

      • onMessage

        void onMessage(CharSequence channel,
                       M msg)
        Invokes on every message in topic
        Parameters:
        channel - of topic
        msg - topic message