BUG-5280: add maxMessages field to ConnectClientSuccess

[controller.git] / opendaylight / md-sal / cds-access-api / src / main / java / org / opendaylight / controller / cluster / access / commands / ConnectClientSuccessProxyV1.java

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 d05ca37dd0fc5b22c860f7dafcf0b176f54e4e8d..6c9ae2a19ad4eb4840d9e5ab903b98d4995f286a 100644 (file)
--- 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 List<ActorSelection> alternates;
     private ActorRef backend;

+    private long maxMessages;

 
     public ConnectClientSuccessProxyV1() {
         // For Externalizable
 
     public ConnectClientSuccessProxyV1() {
         // For Externalizable


@@ -54,6 +55,8 @@ final class ConnectClientSuccessProxyV1 extends AbstractSuccessProxy<ClientIdent
         for (ActorSelection b : alternates) {
             out.writeObject(b.toSerializationFormat());
         }
         for (ActorSelection b : alternates) {
             out.writeObject(b.toSerializationFormat());
         }

+
+        out.writeLong(maxMessages);

     }
 
     @Override
     }
 
     @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()));
         }
         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) {
     }
 
     @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
     }
 
     @Override