Repository: qpid-broker-j Updated Branches: refs/heads/master 762459018 -> b52830d5a
QPID-6933: [System Tests] Switch to sync publishing in ConsumerPriorityTest Project: http://git-wip-us.apache.org/repos/asf/qpid-broker-j/repo Commit: http://git-wip-us.apache.org/repos/asf/qpid-broker-j/commit/b52830d5 Tree: http://git-wip-us.apache.org/repos/asf/qpid-broker-j/tree/b52830d5 Diff: http://git-wip-us.apache.org/repos/asf/qpid-broker-j/diff/b52830d5 Branch: refs/heads/master Commit: b52830d5a6bf387a359a91aa00b360ac9b17aae4 Parents: 7624590 Author: Alex Rudyy <[email protected]> Authored: Fri Jan 5 10:44:04 2018 +0000 Committer: Alex Rudyy <[email protected]> Committed: Fri Jan 5 10:44:04 2018 +0000 ---------------------------------------------------------------------- .../src/main/java/org/apache/qpid/systests/JmsTestBase.java | 4 ++++ .../extensions/consumerpriority/ConsumerPriorityTest.java | 8 ++++---- 2 files changed, 8 insertions(+), 4 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/qpid-broker-j/blob/b52830d5/systests/qpid-systests-jms-core/src/main/java/org/apache/qpid/systests/JmsTestBase.java ---------------------------------------------------------------------- diff --git a/systests/qpid-systests-jms-core/src/main/java/org/apache/qpid/systests/JmsTestBase.java b/systests/qpid-systests-jms-core/src/main/java/org/apache/qpid/systests/JmsTestBase.java index c94ed67..a37f66d 100644 --- a/systests/qpid-systests-jms-core/src/main/java/org/apache/qpid/systests/JmsTestBase.java +++ b/systests/qpid-systests-jms-core/src/main/java/org/apache/qpid/systests/JmsTestBase.java @@ -40,6 +40,8 @@ import javax.naming.NamingException; import org.junit.BeforeClass; import org.junit.Rule; import org.junit.rules.TestName; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; import org.apache.qpid.server.model.Protocol; import org.apache.qpid.tests.utils.BrokerAdmin; @@ -47,6 +49,7 @@ import org.apache.qpid.tests.utils.BrokerAdminUsingTestBase; public abstract class JmsTestBase extends BrokerAdminUsingTestBase { + private static final Logger LOGGER = LoggerFactory.getLogger(JmsTestBase.class); private static JmsProvider _jmsProvider; private static AmqpManagementFacade _managementFacade; @@ -66,6 +69,7 @@ public abstract class JmsTestBase extends BrokerAdminUsingTestBase { _jmsProvider = new QpidJmsClient0xProvider(); } + LOGGER.debug("Test receive timeout is {} milliseconds", getReceiveTimeout()); } protected ConnectionBuilder getConnectionBuilder() http://git-wip-us.apache.org/repos/asf/qpid-broker-j/blob/b52830d5/systests/qpid-systests-jms_1.1/src/test/java/org/apache/qpid/systests/jms_1_1/extensions/consumerpriority/ConsumerPriorityTest.java ---------------------------------------------------------------------- diff --git a/systests/qpid-systests-jms_1.1/src/test/java/org/apache/qpid/systests/jms_1_1/extensions/consumerpriority/ConsumerPriorityTest.java b/systests/qpid-systests-jms_1.1/src/test/java/org/apache/qpid/systests/jms_1_1/extensions/consumerpriority/ConsumerPriorityTest.java index 3047cb3..78342d2 100644 --- a/systests/qpid-systests-jms_1.1/src/test/java/org/apache/qpid/systests/jms_1_1/extensions/consumerpriority/ConsumerPriorityTest.java +++ b/systests/qpid-systests-jms_1.1/src/test/java/org/apache/qpid/systests/jms_1_1/extensions/consumerpriority/ConsumerPriorityTest.java @@ -60,7 +60,7 @@ public class ConsumerPriorityTest extends JmsTestBase final Connection consumingConnection = getConnection(); try { - final Connection producingConnection = getConnection(); + final Connection producingConnection = getConnectionBuilder().setSyncPublish(true).build(); try { final Session consumingSession = consumingConnection.createSession(false, Session.AUTO_ACKNOWLEDGE); @@ -116,7 +116,7 @@ public class ConsumerPriorityTest extends JmsTestBase final Connection consumingConnection = getConnection(); try { - final Connection producingConnection = getConnection(); + final Connection producingConnection = getConnectionBuilder().setSyncPublish(true).build(); try { final Session consumingSession = consumingConnection.createSession(false, Session.AUTO_ACKNOWLEDGE); @@ -175,7 +175,7 @@ public class ConsumerPriorityTest extends JmsTestBase final Connection consumingConnection = getConnection(); try { - final Connection producingConnection = getConnection(); + final Connection producingConnection = getConnectionBuilder().setSyncPublish(true).build(); try { final Session consumingSession = consumingConnection.createSession(false, Session.AUTO_ACKNOWLEDGE); @@ -238,7 +238,7 @@ public class ConsumerPriorityTest extends JmsTestBase Connection consumingConnection = getConnection(); try { - Connection producingConnection = getConnection(); + Connection producingConnection = getConnectionBuilder().setSyncPublish(true).build(); try { Session consumingSession = consumingConnection.createSession(false, Session.AUTO_ACKNOWLEDGE); --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
