X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?p=controller.git;a=blobdiff_plain;f=opendaylight%2Fmd-sal%2Fcds-access-api%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fcluster%2Faccess%2Fcommands%2FConnectClientSuccessProxyV1.java;h=6c9ae2a19ad4eb4840d9e5ab903b98d4995f286a;hp=d05ca37dd0fc5b22c860f7dafcf0b176f54e4e8d;hb=a73c52b4740be611728b4f9c70c67b2b36cf3916;hpb=edd61d79da614388134b0e0a618010c91e9c91bd

diff --git a/opendaylight/md-sal/cds-access-api/src/main/java/org/opendaylight/controller/cluster/access/commands/ConnectClientSuccessProxyV1.java b/opendaylight/md-sal/cds-access-api/src/main/java/org/opendaylight/controller/cluster/access/commands/ConnectClientSuccessProxyV1.java
index d05ca37dd0..6c9ae2a19a 100644
--- a/opendaylight/md-sal/cds-access-api/src/main/java/org/opendaylight/controller/cluster/access/commands/ConnectClientSuccessProxyV1.java
+++ b/opendaylight/md-sal/cds-access-api/src/main/java/org/opendaylight/controller/cluster/access/commands/ConnectClientSuccessProxyV1.java
@@ -32,6 +32,7 @@ final class ConnectClientSuccessProxyV1 extends AbstractSuccessProxy<ClientIdent
 
     private List<ActorSelection> alternates;
     private ActorRef backend;
+    private long maxMessages;
 
     public ConnectClientSuccessProxyV1() {
         // For Externalizable
@@ -54,6 +55,8 @@ final class ConnectClientSuccessProxyV1 extends AbstractSuccessProxy<ClientIdent
         for (ActorSelection b : alternates) {
             out.writeObject(b.toSerializationFormat());
         }
+
+        out.writeLong(maxMessages);
     }
 
     @Override
@@ -71,11 +74,13 @@ final class ConnectClientSuccessProxyV1 extends AbstractSuccessProxy<ClientIdent
         for (int i = 0; i < backendsSize; ++i) {
             alternates.add(ActorSelection.apply(ActorRef.noSender(), (String)in.readObject()));
         }
+
+        maxMessages = in.readLong();
     }
 
     @Override
     protected ConnectClientSuccess createSuccess(final ClientIdentifier target) {
-        return new ConnectClientSuccess(target, backend, alternates, Optional.empty());
+        return new ConnectClientSuccess(target, backend, alternates, Optional.empty(), maxMessages);
     }
 
     @Override