X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;ds=sidebyside;f=opendaylight%2Fmd-sal%2Fsal-distributed-datastore%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fcluster%2Fdatastore%2Fidentifiers%2FTransactionChainIdentifier.java;h=851e23ced009d733e219e3769369e5d23a6fc9cf;hb=refs%2Fchanges%2F02%2F38802%2F16;hp=4b1c096f7b14e99321d3808f596bb5150439b068;hpb=104ce145c9cd637c9b1caecfe0fe02c4ce4f343c;p=controller.git

diff --git a/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/identifiers/TransactionChainIdentifier.java b/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/identifiers/TransactionChainIdentifier.java
index 4b1c096f7b..851e23ced0 100644
--- a/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/identifiers/TransactionChainIdentifier.java
+++ b/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/identifiers/TransactionChainIdentifier.java
@@ -11,6 +11,7 @@ package org.opendaylight.controller.cluster.datastore.identifiers;
 import com.google.common.base.Supplier;
 import com.google.common.base.Suppliers;
 import java.util.concurrent.atomic.AtomicLong;
+import org.opendaylight.controller.cluster.access.concepts.MemberName;
 
 public class TransactionChainIdentifier {
 
@@ -18,18 +19,15 @@ public class TransactionChainIdentifier {
 
     private final AtomicLong txnCounter = new AtomicLong();
     private final Supplier<String> stringRepresentation;
-    private final String memberName;
+    private final MemberName memberName;
 
-    public TransactionChainIdentifier(final String memberName, final long counter) {
+    public TransactionChainIdentifier(final MemberName memberName, final long counter) {
         this.memberName = memberName;
-        stringRepresentation = Suppliers.memoize(new Supplier<String>() {
-            @Override
-            public String get() {
-                final StringBuilder sb = new StringBuilder();
-                sb.append(memberName).append(CHAIN_SEPARATOR);
-                sb.append(counter);
-                return sb.toString();
-            }
+        stringRepresentation = Suppliers.memoize(() -> {
+            final StringBuilder sb = new StringBuilder();
+            sb.append(memberName.getName()).append(CHAIN_SEPARATOR);
+            sb.append(counter);
+            return sb.toString();
         });
     }
     @Override
@@ -41,7 +39,7 @@ public class TransactionChainIdentifier {
         return new ChainedTransactionIdentifier(this, txnCounter.incrementAndGet());
     }
 
-    public String getMemberName() {
+    public MemberName getMemberName() {
         return memberName;
     }
 }