import akka.actor.ActorRef;
import akka.actor.ActorSelection;
-import com.google.common.base.Optional;
import java.util.ArrayList;
import java.util.Collection;
import java.util.EventListener;
-import java.util.Map.Entry;
import org.opendaylight.controller.cluster.datastore.messages.EnableNotification;
import org.opendaylight.controller.cluster.datastore.messages.ListenerRegistrationMessage;
import org.opendaylight.yangtools.concepts.ListenerRegistration;
-import org.opendaylight.yangtools.yang.data.api.schema.tree.DataTreeCandidate;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
abstract class AbstractDataListenerSupport<L extends EventListener, M extends ListenerRegistrationMessage,
D extends DelayedListenerRegistration<L, M>, R extends ListenerRegistration<L>>
- extends LeaderLocalDelegateFactory<M, R, Optional<DataTreeCandidate>> {
+ extends LeaderLocalDelegateFactory<M, R> {
private final Logger log = LoggerFactory.getLogger(getClass());
private final ArrayList<D> delayedListenerRegistrations = new ArrayList<>();
final ListenerRegistration<L> registration;
if (hasLeader && message.isRegisterOnAllInstances() || isLeader) {
- final Entry<R, Optional<DataTreeCandidate>> res = createDelegate(message);
- registration = res.getKey();
+ registration = createDelegate(message);
} else {
log.debug("{}: Shard is not the leader - delaying registration", persistenceId());