Repository: activemq-artemis Updated Branches: refs/heads/master 5a31e7035 -> 9956f951a
NO-JIRA: Avoiding a test failure on slow Jenkins JmsNettyNioStressTest is using Persistent messages depending on the hardware used this may eventually fail. Project: http://git-wip-us.apache.org/repos/asf/activemq-artemis/repo Commit: http://git-wip-us.apache.org/repos/asf/activemq-artemis/commit/9956f951 Tree: http://git-wip-us.apache.org/repos/asf/activemq-artemis/tree/9956f951 Diff: http://git-wip-us.apache.org/repos/asf/activemq-artemis/diff/9956f951 Branch: refs/heads/master Commit: 9956f951a6e4cff2512f0f932cbd3aac58878484 Parents: 5a31e70 Author: Clebert Suconic <clebertsuco...@apache.org> Authored: Fri Mar 31 19:28:12 2017 -0400 Committer: Clebert Suconic <clebertsuco...@apache.org> Committed: Fri Mar 31 19:28:13 2017 -0400 ---------------------------------------------------------------------- .../artemis/tests/integration/client/JmsNettyNioStressTest.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/9956f951/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/client/JmsNettyNioStressTest.java ---------------------------------------------------------------------- diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/client/JmsNettyNioStressTest.java b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/client/JmsNettyNioStressTest.java index 081dc79..1113e4b 100644 --- a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/client/JmsNettyNioStressTest.java +++ b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/client/JmsNettyNioStressTest.java @@ -161,7 +161,7 @@ public class JmsNettyNioStressTest extends ActiveMQTestBase { try { session = connectionProducer.createSession(true, Session.SESSION_TRANSACTED); MessageProducer messageProducer = session.createProducer(ActiveMQDestination.createQueue("queue")); - messageProducer.setDeliveryMode(DeliveryMode.PERSISTENT); + messageProducer.setDeliveryMode(DeliveryMode.NON_PERSISTENT); for (int i = 0; i < numberOfMessages; i++) { BytesMessage message = session.createBytesMessage(); @@ -199,7 +199,7 @@ public class JmsNettyNioStressTest extends ActiveMQTestBase { session = connectionConsumerProducer.createSession(true, Session.SESSION_TRANSACTED); MessageConsumer consumer = session.createConsumer(ActiveMQDestination.createQueue("queue")); MessageProducer messageProducer = session.createProducer(ActiveMQDestination.createQueue("queue2")); - messageProducer.setDeliveryMode(DeliveryMode.PERSISTENT); + messageProducer.setDeliveryMode(DeliveryMode.NON_PERSISTENT); for (int i = 0; i < numberOfMessages; i++) { BytesMessage message = (BytesMessage) consumer.receive(5000); if (message == null) {