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:59 UTC
[qpid-broker-j] 17/21: QPID-8350: [Tests][AMQP 1.0] Use randomly
generated name for unknown destinations in AnonymousTerminusTest
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 019905cfd608061f0bd79f0c26d9b04dbad3205a
Author: Alex Rudyy <or...@apache.org>
AuthorDate: Wed Aug 21 17:11:22 2019 +0100
QPID-8350: [Tests][AMQP 1.0] Use randomly generated name for unknown destinations in AnonymousTerminusTest
---
.../anonymousterminus/AnonymousTerminusTest.java | 20 +++++++++++++-------
1 file changed, 13 insertions(+), 7 deletions(-)
diff --git a/systests/protocol-tests-amqp-1-0/src/test/java/org/apache/qpid/tests/protocol/v1_0/extensions/anonymousterminus/AnonymousTerminusTest.java b/systests/protocol-tests-amqp-1-0/src/test/java/org/apache/qpid/tests/protocol/v1_0/extensions/anonymousterminus/AnonymousTerminusTest.java
index 6449e31..369abf7 100644
--- a/systests/protocol-tests-amqp-1-0/src/test/java/org/apache/qpid/tests/protocol/v1_0/extensions/anonymousterminus/AnonymousTerminusTest.java
+++ b/systests/protocol-tests-amqp-1-0/src/test/java/org/apache/qpid/tests/protocol/v1_0/extensions/anonymousterminus/AnonymousTerminusTest.java
@@ -58,6 +58,7 @@ import org.apache.qpid.server.protocol.v1_0.type.transport.Error;
import org.apache.qpid.server.protocol.v1_0.type.transport.Flow;
import org.apache.qpid.server.protocol.v1_0.type.transport.Open;
import org.apache.qpid.server.protocol.v1_0.type.transport.Role;
+import org.apache.qpid.server.util.StringUtil;
import org.apache.qpid.tests.protocol.Response;
import org.apache.qpid.tests.protocol.SpecificationTest;
import org.apache.qpid.tests.protocol.v1_0.FrameTransport;
@@ -139,7 +140,7 @@ public class AnonymousTerminusTest extends BrokerAdminUsingTestBase
.consumeResponse(Flow.class)
.assertLatestResponse(Flow.class, this::assumeSufficientCredits)
.transferDeliveryId()
- .transferPayload(generateMessagePayloadToDestination("Unknown"))
+ .transferPayload(generateMessagePayloadToDestination(getNonExistingDestinationName()))
.transferSettled(Boolean.TRUE)
.transferDeliveryTag(_deliveryTag)
.transfer();
@@ -180,7 +181,7 @@ public class AnonymousTerminusTest extends BrokerAdminUsingTestBase
.consumeResponse(Flow.class)
.assertLatestResponse(Flow.class, this::assumeSufficientCredits)
.transferDeliveryId()
- .transferPayload(generateMessagePayloadToDestination("Unknown"))
+ .transferPayload(generateMessagePayloadToDestination(getNonExistingDestinationName()))
.transferDeliveryTag(_deliveryTag)
.transfer()
.consumeResponse();
@@ -228,7 +229,7 @@ public class AnonymousTerminusTest extends BrokerAdminUsingTestBase
.consumeResponse(Flow.class)
.assertLatestResponse(Flow.class, this::assumeSufficientCredits)
.transferDeliveryId()
- .transferPayload(generateMessagePayloadToDestination("Unknown"))
+ .transferPayload(generateMessagePayloadToDestination(getNonExistingDestinationName()))
.transferDeliveryTag(_deliveryTag)
.transfer();
@@ -344,7 +345,7 @@ public class AnonymousTerminusTest extends BrokerAdminUsingTestBase
.assertLatestResponse(Flow.class, this::assumeSufficientCredits)
.transferDeliveryId()
.transferHandle(linkHandle)
- .transferPayload(generateMessagePayloadToDestination("Unknown"))
+ .transferPayload(generateMessagePayloadToDestination(getNonExistingDestinationName()))
.transferDeliveryTag(_deliveryTag)
.transferTransactionalStateFromCurrentTransaction()
.transferSettled(Boolean.FALSE)
@@ -392,7 +393,7 @@ public class AnonymousTerminusTest extends BrokerAdminUsingTestBase
.assertLatestResponse(Flow.class, this::assumeSufficientCredits)
.transferDeliveryId()
.transferHandle(linkHandle)
- .transferPayload(generateMessagePayloadToDestination("Unknown"))
+ .transferPayload(generateMessagePayloadToDestination(getNonExistingDestinationName()))
.transferDeliveryId(UnsignedInteger.valueOf(1))
.transferDeliveryTag(_deliveryTag)
.transferTransactionalStateFromCurrentTransaction()
@@ -463,7 +464,7 @@ public class AnonymousTerminusTest extends BrokerAdminUsingTestBase
.assertLatestResponse(Flow.class, this::assumeSufficientCredits)
.transferDeliveryId()
.transferHandle(linkHandle)
- .transferPayload(generateMessagePayloadToDestination("Unknown"))
+ .transferPayload(generateMessagePayloadToDestination(getNonExistingDestinationName()))
.transferDeliveryTag(_deliveryTag)
.transferTransactionalStateFromCurrentTransaction()
.transferSettled(Boolean.TRUE)
@@ -530,7 +531,7 @@ public class AnonymousTerminusTest extends BrokerAdminUsingTestBase
.assertLatestResponse(Flow.class, this::assumeSufficientCredits)
.transferDeliveryId()
.transferHandle(linkHandle)
- .transferPayload(generateMessagePayloadToDestination("Unknown"))
+ .transferPayload(generateMessagePayloadToDestination(getNonExistingDestinationName()))
.transferDeliveryTag(_deliveryTag)
.transferTransactionalStateFromCurrentTransaction()
.transferSettled(Boolean.TRUE)
@@ -543,6 +544,11 @@ public class AnonymousTerminusTest extends BrokerAdminUsingTestBase
}
}
+ private String getNonExistingDestinationName()
+ {
+ return String.format("%sNonExisting%s", getTestName(), new StringUtil().randomAlphaNumericString(10));
+ }
+
private Disposition getDispositionForDeliveryId(final Interaction interaction,
final UnsignedInteger deliveryId) throws Exception
{
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@qpid.apache.org
For additional commands, e-mail: commits-help@qpid.apache.org