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