public class CountDownServiceServerListener<T,S> extends CountDownRegistrantListener<ServiceServer<T,S>> implements ServiceServerListener<T,S>
ServiceServerListener
which uses CountDownLatch
to track
message invocations.Modifier and Type | Method and Description |
---|---|
void |
awaitShutdown()
Wait for shutdown.
|
boolean |
awaitShutdown(long timeout,
java.util.concurrent.TimeUnit unit)
Wait for shutdown within the given time period.
|
static <T,S> CountDownServiceServerListener<T,S> |
newDefault()
Construct a
CountDownServiceServerListener with all counts set to
1. |
static <T,S> CountDownServiceServerListener<T,S> |
newFromCounts(int masterRegistrationSuccessCount,
int masterRegistrationFailureCount,
int masterUnregistrationSuccessCount,
int masterUnregistrationFailureCount) |
void |
onShutdown(ServiceServer<T,S> server) |
awaitMasterRegistrationFailure, awaitMasterRegistrationFailure, awaitMasterRegistrationSuccess, awaitMasterRegistrationSuccess, awaitMasterUnregistrationFailure, awaitMasterUnregistrationFailure, awaitMasterUnregistrationSuccess, awaitMasterUnregistrationSuccess, onMasterRegistrationFailure, onMasterRegistrationSuccess, onMasterUnregistrationFailure, onMasterUnregistrationSuccess
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
onMasterRegistrationFailure, onMasterRegistrationSuccess, onMasterUnregistrationFailure, onMasterUnregistrationSuccess
public static <T,S> CountDownServiceServerListener<T,S> newDefault()
CountDownServiceServerListener
with all counts set to
1.public static <T,S> CountDownServiceServerListener<T,S> newFromCounts(int masterRegistrationSuccessCount, int masterRegistrationFailureCount, int masterUnregistrationSuccessCount, int masterUnregistrationFailureCount)
masterRegistrationSuccessCount
- the number of successful master registrations to wait formasterRegistrationFailureCount
- the number of failing master registrations to wait formasterUnregistrationSuccessCount
- the number of successful master unregistrations to wait formasterUnregistrationFailureCount
- the number of failing master unregistrations to wait forpublic void onShutdown(ServiceServer<T,S> server)
onShutdown
in interface ServiceServerListener<T,S>
server
- the ServiceServer
which has been shut downpublic void awaitShutdown() throws java.lang.InterruptedException
java.lang.InterruptedException
public boolean awaitShutdown(long timeout, java.util.concurrent.TimeUnit unit) throws java.lang.InterruptedException
timeout
- the maximum time to waitunit
- the time unit of the timeout
argumenttrue
if shutdown happened within the time period,
false
otherwisejava.lang.InterruptedException