Class DefaultTopicDistributionService

    • Constructor Detail

      • DefaultTopicDistributionService

        public DefaultTopicDistributionService()
    • Method Detail

      • distributeMessage

        public void distributeMessage​(Topic<?> topic,
                                      java.lang.Object message)
        Description copied from interface: TopicDistributionService
        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
        Specified by:
        distributeMessage in interface TopicDistributionService
        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
      • getFilter

        public Filter getFilter()
        Description copied from interface: InstanceLifecycleListener
        This returns a filter that tells the system whether a particular descriptor should be handled by this lifecycle listener. The filter can be called at any time
        Specified by:
        getFilter in interface InstanceLifecycleListener
        Returns:
        The filter that tells the system if this listener applies to this descriptor. If this returns null then this Listener will apply to ALL descriptors.
      • findMethodOnDifferentClass

        private java.lang.reflect.Method findMethodOnDifferentClass​(java.lang.Class<?> findOnMe,
                                                                    java.lang.reflect.Method method)
      • generateSubscriberInfo

        private static DefaultTopicDistributionService.SubscriberInfo generateSubscriberInfo​(ActiveDescriptor<?> injecteeDescriptor,
                                                                                             java.lang.reflect.Method subscriber,
                                                                                             java.lang.reflect.Method useSubscriber,
                                                                                             int subscribeToPosition,
                                                                                             java.lang.annotation.Annotation[][] paramAnnotations)
      • lifecycleEvent

        public void lifecycleEvent​(InstanceLifecycleEvent lifecycleEvent)
        Description copied from interface: InstanceLifecycleListener
        This method will be called when any lifecycle event occurs. The currently supported lifecycle events are PRE_PRODUCTION, POST_PRODUCTION and PRE_DESTRUCTION. Code should be written to allow for future events to be generated. This method should not throw exceptions
        Specified by:
        lifecycleEvent in interface InstanceLifecycleListener
        Parameters:
        lifecycleEvent - The event that has occurred, will not be null
      • configurationChanged

        public void configurationChanged()
        Description copied from interface: DynamicConfigurationListener
        This method is called when the set of descriptors in this service locator has been changed. Changes to parent service locators descriptors will not be reported. These services are called back on the thread doing the DynamicConfiguration.commit() so care should be taken to do any work quickly. Any exception thrown from this method will be ignored. A commit that failed will not be reported to this method
        Specified by:
        configurationChanged in interface DynamicConfigurationListener