private List<ActorSelection> alternates;
private ActorRef backend;
+ private long maxMessages;
public ConnectClientSuccessProxyV1() {
// For Externalizable
for (ActorSelection b : alternates) {
out.writeObject(b.toSerializationFormat());
}
+
+ out.writeLong(maxMessages);
}
@Override
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