You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by or...@apache.org on 2019/08/21 16:35:46 UTC
[qpid-broker-j] 04/21: QPID-8349: [Tests][AMQP 1.0] Add methods to
set delivery id from internal counter
This is an automated email from the ASF dual-hosted git repository.
orudyy pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/qpid-broker-j.git
commit a545246d53288521486b51b383b9a44aa4fdc9ff
Author: Alex Rudyy <or...@apache.org>
AuthorDate: Mon Aug 19 16:38:05 2019 +0100
QPID-8349: [Tests][AMQP 1.0] Add methods to set delivery id from internal counter
---
.../org/apache/qpid/tests/protocol/v1_0/Interaction.java | 14 +++++++++++++-
1 file changed, 13 insertions(+), 1 deletion(-)
diff --git a/systests/protocol-tests-amqp-1-0/src/main/java/org/apache/qpid/tests/protocol/v1_0/Interaction.java b/systests/protocol-tests-amqp-1-0/src/main/java/org/apache/qpid/tests/protocol/v1_0/Interaction.java
index 4df4db0..98ffe45 100644
--- a/systests/protocol-tests-amqp-1-0/src/main/java/org/apache/qpid/tests/protocol/v1_0/Interaction.java
+++ b/systests/protocol-tests-amqp-1-0/src/main/java/org/apache/qpid/tests/protocol/v1_0/Interaction.java
@@ -159,7 +159,7 @@ public class Interaction extends AbstractInteraction<Interaction>
_transfer = new Transfer();
_transfer.setHandle(defaultLinkHandle);
_transfer.setDeliveryTag(new Binary("testDeliveryTag".getBytes(StandardCharsets.UTF_8)));
- _transfer.setDeliveryId(getNextDeliveryId());
+ _transfer.setDeliveryId(UnsignedInteger.valueOf(_deliveryIdCounter));
_disposition = new Disposition();
_disposition.setFirst(UnsignedInteger.ZERO);
@@ -671,6 +671,12 @@ public class Interaction extends AbstractInteraction<Interaction>
return this;
}
+ public Interaction flowNextOutgoingId()
+ {
+ _flow.setNextOutgoingId(UnsignedInteger.valueOf(_deliveryIdCounter));
+ return this;
+ }
+
public Interaction flowEcho(final Boolean echo)
{
_flow.setEcho(echo);
@@ -761,6 +767,12 @@ public class Interaction extends AbstractInteraction<Interaction>
return this;
}
+ public Interaction transferDeliveryId()
+ {
+ _transfer.setDeliveryId(getNextDeliveryId());
+ return this;
+ }
+
public Interaction transferDeliveryTag(final Binary deliveryTag)
{
_transfer.setDeliveryTag(deliveryTag);
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@qpid.apache.org
For additional commands, e-mail: commits-help@qpid.apache.org