private static final Logger LOG = LoggerFactory.getLogger(ActiveServiceGroup.class);
- private final DOMEntityOwnershipService entityOwnershipService;
- private final String identifier;
+ private final @NonNull DOMEntityOwnershipService entityOwnershipService;
+ private final @NonNull String identifier;
/* Entity instances */
private final @NonNull DOMEntity serviceEntity;
@Override
ListenableFuture<?> closeClusterSingletonGroup() {
- final ListenableFuture<?> ret = destroyGroup();
+ final var ret = destroyGroup();
members.clear();
markDirty();
@Override
void registerService(final ServiceRegistration reg) {
- final ClusterSingletonService service = verifyRegistration(reg);
+ final var service = verifyRegistration(reg);
checkNotClosed();
checkState(initialized, "Service group %s is not initialized yet", identifier);
}
private ClusterSingletonService verifyRegistration(final ServiceRegistration reg) {
- final ClusterSingletonService service = reg.getInstance();
+ final var service = reg.getInstance();
verify(identifier.equals(service.getIdentifier().getName()));
return service;
}