commit a545246d53288521486b51b383b9a44aa4fdc9ff
author Alex Rudyy <orudyy@apache.org> Mon Aug 19 16:38:05 2019 +0100
committer Alex Rudyy <orudyy@apache.org> Wed Aug 21 17:34:09 2019 +0100
tree 8fcd696657294159e5ecca1ace58ad8facf0a6dc
parent a8d14bfb38721b3b6674c312d4cc0c552372491b

QPID-8349: [Tests][AMQP 1.0] Add methods to set delivery id from internal counter

systests/protocol-tests-amqp-1-0/src/main/java/org/apache/qpid/tests/protocol/v1_0/Interaction.java

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 @@
         _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 @@
         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 @@
         return this;
     }
 
+    public Interaction transferDeliveryId()
+    {
+        _transfer.setDeliveryId(getNextDeliveryId());
+        return this;
+    }
+
     public Interaction transferDeliveryTag(final Binary deliveryTag)
     {
         _transfer.setDeliveryTag(deliveryTag);