* - its minimum supported ABI version
* - its maximum supported ABI version
*
+ * <p>
* It also includes request stream sequencing information.
*
* @author Robert Varga
private final ABIVersion minVersion;
private final ABIVersion maxVersion;
- private final long resumeSequence;
- public ConnectClientRequest(final ClientIdentifier identifier, final ActorRef replyTo, final ABIVersion minVersion,
- final ABIVersion maxVersion) {
- this(identifier, replyTo, minVersion, maxVersion, 0);
+ ConnectClientRequest(final ClientIdentifier identifier, final long txSequence, final ActorRef replyTo,
+ final ABIVersion minVersion, final ABIVersion maxVersion) {
+ super(identifier, txSequence, replyTo);
+ this.minVersion = Preconditions.checkNotNull(minVersion);
+ this.maxVersion = Preconditions.checkNotNull(maxVersion);
}
public ConnectClientRequest(final ClientIdentifier identifier, final ActorRef replyTo, final ABIVersion minVersion,
- final ABIVersion maxVersion, final long resumeSequence) {
- super(identifier, replyTo);
- this.minVersion = Preconditions.checkNotNull(minVersion);
- this.maxVersion = Preconditions.checkNotNull(maxVersion);
- this.resumeSequence = resumeSequence;
+ final ABIVersion maxVersion) {
+ this(identifier, 0, replyTo, minVersion, maxVersion);
}
private ConnectClientRequest(final ConnectClientRequest request, final ABIVersion version) {
super(request, version);
this.minVersion = request.minVersion;
this.maxVersion = request.maxVersion;
- this.resumeSequence = request.resumeSequence;
}
public ABIVersion getMinVersion() {
return maxVersion;
}
- public long getResumeSequence() {
- return resumeSequence;
- }
-
@Override
- public final ConnectClientFailure toRequestFailure(final RequestException cause) {
- return new ConnectClientFailure(getTarget(), cause);
+ public ConnectClientFailure toRequestFailure(final RequestException cause) {
+ return new ConnectClientFailure(getTarget(), getSequence(), cause);
}
@Override
- protected AbstractRequestProxy<ClientIdentifier, ConnectClientRequest> externalizableProxy(final ABIVersion version) {
+ protected AbstractRequestProxy<ClientIdentifier, ConnectClientRequest> externalizableProxy(
+ final ABIVersion version) {
return new ConnectClientRequestProxyV1(this);
}
}
@Override
- protected @Nonnull ToStringHelper addToStringAttributes(final @Nonnull ToStringHelper toStringHelper) {
- return super.addToStringAttributes(toStringHelper).add("minVersion", minVersion).add("maxVersion", maxVersion)
- .add("resumeSequence", resumeSequence);
+ @Nonnull
+ protected ToStringHelper addToStringAttributes(@Nonnull final ToStringHelper toStringHelper) {
+ return super.addToStringAttributes(toStringHelper).add("minVersion", minVersion).add("maxVersion", maxVersion);
}
}