Interface DefaultTopicDistributionErrorService


@Contract public interface DefaultTopicDistributionErrorService
When using the TopicDistributionService added with ServiceLocatorUtilities.enableTopicDistribution(org.glassfish.hk2.api.ServiceLocator) if a subscriber throws an exception this service will be called. All implementation of this service will be called.
  • Method Details

    • subscribersFailed

      void subscribersFailed(Topic<?> topic, Object message, MultiException error)
      This method will be called once per Topic.publish(Object) call after the message has been distributed to all subscribers. The MultiException will contain the errors from any subscribers that threw exceptions. This method will not be called if no subscribers threw exceptions
      Parameters:
      topic - The topic that the message was sent to
      message - The message that was sent to the topic
      error - The exceptions thrown by the subscribers of this Topic