Set types in ZkController callables

This commit is contained in:
Tomas Fernandez Lobbe 2019-02-06 16:47:03 -08:00 committed by Tomas Fernandez Lobbe
parent 87564a3e19
commit f2b84577a2
1 changed files with 2 additions and 2 deletions

View File

@ -252,7 +252,7 @@ public class ZkController implements Closeable {
// ref is held as a HashSet since we clone the set before notifying to avoid synchronizing too long // ref is held as a HashSet since we clone the set before notifying to avoid synchronizing too long
private HashSet<OnReconnect> reconnectListeners = new HashSet<OnReconnect>(); private HashSet<OnReconnect> reconnectListeners = new HashSet<OnReconnect>();
private class RegisterCoreAsync implements Callable { private class RegisterCoreAsync implements Callable<Object> {
CoreDescriptor descriptor; CoreDescriptor descriptor;
boolean recoverReloadedCores; boolean recoverReloadedCores;
@ -272,7 +272,7 @@ public class ZkController implements Closeable {
} }
// notifies registered listeners after the ZK reconnect in the background // notifies registered listeners after the ZK reconnect in the background
private static class OnReconnectNotifyAsync implements Callable { private static class OnReconnectNotifyAsync implements Callable<Object> {
private final OnReconnect listener; private final OnReconnect listener;