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 <[email protected]> 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: [email protected] For additional commands, e-mail: [email protected]
