public class Selectors extends Object
| Constructor and Description |
|---|
Selectors(ClusterManager clusterManager) |
| Modifier and Type | Method and Description |
|---|---|
void |
dataLost() |
void |
dataReceived(String address,
List<RegistrationInfo> registrations,
boolean isUpdate) |
boolean |
hasEntryFor(String address) |
<T> void |
withSelector(Message<?> message,
Promise<T> promise,
BiConsumer<Promise<T>,RoundRobinSelector> task) |
public Selectors(ClusterManager clusterManager)
public <T> void withSelector(Message<?> message, Promise<T> promise, BiConsumer<Promise<T>,RoundRobinSelector> task)
public void dataReceived(String address, List<RegistrationInfo> registrations, boolean isUpdate)
public void dataLost()
public boolean hasEntryFor(String address)
Copyright © 2021. All rights reserved.