You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by cl...@apache.org on 2020/11/10 17:00:52 UTC
[activemq-artemis] branch master updated: NO-JIRA improving test
This is an automated email from the ASF dual-hosted git repository.
clebertsuconic pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/activemq-artemis.git
The following commit(s) were added to refs/heads/master by this push:
new 62099e8 NO-JIRA improving test
62099e8 is described below
commit 62099e86d3a5ed577e6049aee36417233976628a
Author: Clebert Suconic <cl...@apache.org>
AuthorDate: Tue Nov 10 11:57:56 2020 -0500
NO-JIRA improving test
---
.../activemq/artemis/tests/integration/paging/PagingTest.java | 10 +++++-----
1 file changed, 5 insertions(+), 5 deletions(-)
diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/paging/PagingTest.java b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/paging/PagingTest.java
index bbf96ab..ec57605 100644
--- a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/paging/PagingTest.java
+++ b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/paging/PagingTest.java
@@ -103,6 +103,7 @@ import org.apache.activemq.artemis.jms.client.ActiveMQConnectionFactory;
import org.apache.activemq.artemis.logs.AssertionLoggerHandler;
import org.apache.activemq.artemis.spi.core.security.ActiveMQSecurityManagerImpl;
import org.apache.activemq.artemis.tests.util.ActiveMQTestBase;
+import org.apache.activemq.artemis.tests.util.RandomUtil;
import org.apache.activemq.artemis.tests.util.Wait;
import org.apache.activemq.artemis.utils.RetryRule;
import org.apache.activemq.artemis.utils.actors.ArtemisExecutor;
@@ -759,15 +760,14 @@ public class PagingTest extends ActiveMQTestBase {
server.start();
- String queue = "purgeQueue";
- SimpleString ssQueue = new SimpleString(queue);
- server.addAddressInfo(new AddressInfo(ssQueue, RoutingType.ANYCAST));
- QueueImpl purgeQueue = (QueueImpl) server.createQueue(new QueueConfiguration(ssQueue).setRoutingType(RoutingType.ANYCAST).setMaxConsumers(1).setPurgeOnNoConsumers(true).setAutoCreateAddress(false));
+ SimpleString queue = new SimpleString("testPurge:" + RandomUtil.randomString());
+ server.addAddressInfo(new AddressInfo(queue, RoutingType.ANYCAST));
+ QueueImpl purgeQueue = (QueueImpl) server.createQueue(new QueueConfiguration(queue).setRoutingType(RoutingType.ANYCAST).setMaxConsumers(1).setPurgeOnNoConsumers(true).setAutoCreateAddress(false));
ActiveMQConnectionFactory cf = new ActiveMQConnectionFactory();
Connection connection = cf.createConnection();
Session session = connection.createSession(true, Session.SESSION_TRANSACTED);
- javax.jms.Queue jmsQueue = session.createQueue(queue);
+ javax.jms.Queue jmsQueue = session.createQueue(queue.toString());
MessageProducer producer = session.createProducer(jmsQueue);