Class ServiceDiscoveryAnnouncerRetryTask
- java.lang.Object
-
- com.linkedin.venice.servicediscovery.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 aServiceDiscoveryAnnouncer
in the case of registration failure. It is a runnable task that is scheduled to register each service discovery announcer everyserviceDiscoveryRegistrationRetryMS
milliseconds.
-
-
Constructor Summary
Constructors Constructor Description ServiceDiscoveryAnnouncerRetryTask(java.util.concurrent.BlockingQueue<ServiceDiscoveryAnnouncer> serviceDiscoveryAnnouncerRetryQueue, long serviceDiscoveryRegistrationRetryMS)
-
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.
-
-
-
Constructor Detail
-
ServiceDiscoveryAnnouncerRetryTask
public ServiceDiscoveryAnnouncerRetryTask(java.util.concurrent.BlockingQueue<ServiceDiscoveryAnnouncer> serviceDiscoveryAnnouncerRetryQueue, long serviceDiscoveryRegistrationRetryMS)
-
-