Interface TopicDistributionService

    • Method Detail

      • distributeMessage

        void distributeMessage​(Topic<?> topic,
                               java.lang.Object message)
        Must distribute the message to all of the matching topic subscribers. Any exception thrown from this method will be ignored. Instead error handling should be performed by the implementation of this message
        Parameters:
        topic - The topic to which to distribute the message. Must not be null
        message - The message to send to the topic. Must not be null