package org.opendaylight.controller.cluster.datastore.entityownership;
import static org.opendaylight.controller.cluster.datastore.entityownership.EntityOwnersModel.createEntity;
-import com.google.common.base.Objects;
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.cluster.access.concepts.MemberName;
import org.opendaylight.controller.md.sal.common.api.clustering.Entity;
import org.opendaylight.yangtools.yang.data.api.schema.LeafNode;
import org.opendaylight.yangtools.yang.data.api.schema.NormalizedNode;
private final String localMemberName;
private final EntityOwnershipListenerSupport listenerSupport;
- EntityOwnerChangeListener(String localMemberName, EntityOwnershipListenerSupport listenerSupport) {
- this.localMemberName = localMemberName;
- this.listenerSupport = listenerSupport;
+ EntityOwnerChangeListener(final MemberName localMemberName, final EntityOwnershipListenerSupport listenerSupport) {
+ this.localMemberName = Verify.verifyNotNull(localMemberName.getName());
+ this.listenerSupport = Preconditions.checkNotNull(listenerSupport);
}
@Override
- public void onDataTreeChanged(Collection<DataTreeCandidate> changes) {
+ public void onDataTreeChanged(final Collection<DataTreeCandidate> changes) {
for(DataTreeCandidate change: changes) {
DataTreeCandidateNode changeRoot = change.getRootNode();
LeafNode<?> ownerLeaf = (LeafNode<?>) changeRoot.getDataAfter().get();
LOG.debug("{}: New owner: {}, Original owner: {}", logId(), newOwner, origOwner);
- if(!Objects.equal(origOwner, newOwner)) {
- boolean isOwner = Objects.equal(localMemberName, newOwner);
- boolean wasOwner = Objects.equal(localMemberName, origOwner);
- boolean hasOwner = newOwner != null && !newOwner.toString().isEmpty();
+ 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());