import com.google.common.base.Optional;
import com.google.common.base.Preconditions;
import com.google.common.base.Strings;
+import com.google.common.base.Verify;
import java.util.Collection;
import java.util.Objects;
-import org.opendaylight.controller.md.sal.common.api.clustering.Entity;
+import org.opendaylight.controller.cluster.access.concepts.MemberName;
+import org.opendaylight.mdsal.eos.dom.api.DOMEntity;
import org.opendaylight.yangtools.yang.data.api.schema.LeafNode;
import org.opendaylight.yangtools.yang.data.api.schema.NormalizedNode;
import org.opendaylight.yangtools.yang.data.api.schema.tree.DataTreeCandidate;
private final String localMemberName;
private final EntityOwnershipListenerSupport listenerSupport;
- EntityOwnerChangeListener(final String localMemberName, final EntityOwnershipListenerSupport listenerSupport) {
- this.localMemberName = Preconditions.checkNotNull(localMemberName);
+ EntityOwnerChangeListener(final MemberName localMemberName, final EntityOwnershipListenerSupport listenerSupport) {
+ this.localMemberName = Verify.verifyNotNull(localMemberName.getName());
this.listenerSupport = Preconditions.checkNotNull(listenerSupport);
}
LOG.debug("{}: New owner: {}, Original owner: {}", logId(), newOwner, origOwner);
- if(!Objects.equals(origOwner, newOwner)) {
- boolean isOwner = Objects.equals(localMemberName, newOwner);
- boolean wasOwner = Objects.equals(localMemberName, origOwner);
+ if (!Objects.equals(origOwner, newOwner)) {
+ boolean isOwner = localMemberName.equals(newOwner);
+ boolean wasOwner = localMemberName.equals(origOwner);
boolean hasOwner = !Strings.isNullOrEmpty(newOwner);
- Entity entity = createEntity(change.getRootPath());
+ DOMEntity entity = createEntity(change.getRootPath());
LOG.debug("{}: Calling notifyEntityOwnershipListeners: entity: {}, wasOwner: {}, isOwner: {}, hasOwner: {}",
logId(), entity, wasOwner, isOwner, hasOwner);