Class ServiceDiscoveryAnnouncerRetryTask

  • All Implemented Interfaces:
    java.lang.Runnable

    public class ServiceDiscoveryAnnouncerRetryTask
    extends java.lang.Object
    implements java.lang.Runnable
    This class is responsible for retrying the registration of a ServiceDiscoveryAnnouncer in the case of registration failure. It is a runnable task that is scheduled to register each service discovery announcer every serviceDiscoveryRegistrationRetryMS milliseconds.
    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      void run()
      If the retry queue is empty, the task will wait until there is an available element in the queue.
      • Methods inherited from class java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
    • Constructor Detail

      • ServiceDiscoveryAnnouncerRetryTask

        public ServiceDiscoveryAnnouncerRetryTask​(java.util.concurrent.BlockingQueue<ServiceDiscoveryAnnouncer> serviceDiscoveryAnnouncerRetryQueue,
                                                  long serviceDiscoveryRegistrationRetryMS)
    • Method Detail

      • run

        public void run()
        If the retry queue is empty, the task will wait until there is an available element in the queue. Each service discovery announcer will retry registration every serviceDiscoveryRegistrationRetryMS milliseconds.
        Specified by:
        run in interface java.lang.Runnable