BUG-5280: expose backing client actor reference

[controller.git] / opendaylight / md-sal / cds-access-client / src / main / java / org / opendaylight / controller / cluster / access / client / BackendInfo.java

diff --git a/opendaylight/md-sal/cds-access-client/src/main/java/org/opendaylight/controller/cluster/access/client/BackendInfo.java b/opendaylight/md-sal/cds-access-client/src/main/java/org/opendaylight/controller/cluster/access/client/BackendInfo.java
index efdfa04b1613feec35894f9899a13445c206ea40..bdffb08c3eb81bf576d3420520db7ef814942013 100644 (file)
--- a/opendaylight/md-sal/cds-access-client/src/main/java/org/opendaylight/controller/cluster/access/client/BackendInfo.java
+++ b/opendaylight/md-sal/cds-access-client/src/main/java/org/opendaylight/controller/cluster/access/client/BackendInfo.java
@@ -26,10 +26,15 @@ import org.opendaylight.controller.cluster.access.ABIVersion;
 public class BackendInfo {
     private final ABIVersion version;
     private final ActorRef actor;
+    private final int maxMessages;
+    private final long sessionId;
 
-    protected BackendInfo(final ActorRef actor, final ABIVersion version) {
+    protected BackendInfo(final ActorRef actor, final long sessionId, final ABIVersion version, final int maxMessages) {
         this.version = Preconditions.checkNotNull(version);
         this.actor = Preconditions.checkNotNull(actor);
+        Preconditions.checkArgument(maxMessages > 0, "Maximum messages has to be positive, not %s", maxMessages);
+        this.maxMessages = maxMessages;
+        this.sessionId = sessionId;
     }
 
     public final ActorRef getActor() {
@@ -40,6 +45,14 @@ public class BackendInfo {
         return version;
     }
 
+    public final int getMaxMessages() {
+        return maxMessages;
+    }
+
+    public final long getSessionId() {
+        return sessionId;
+    }
+
     @Override
     public final int hashCode() {
         return super.hashCode();
@@ -56,6 +69,7 @@ public class BackendInfo {
     }
 
     protected ToStringHelper addToStringAttributes(final ToStringHelper toStringHelper) {
-        return toStringHelper.add("actor", actor).add("version", version);
+        return toStringHelper.add("actor", actor).add("sessionId", sessionId).add("version", version)
+                .add("maxMessages", maxMessages);
     }
 }