QPID-8373: Modify test to use synchrnous publishing and preconfigured receive interval
diff --git a/systests/qpid-systests-http-management/src/test/java/org/apache/qpid/tests/http/endtoend/message/MessageTest.java b/systests/qpid-systests-http-management/src/test/java/org/apache/qpid/tests/http/endtoend/message/MessageTest.java
index 2be0603..bbe6ba7 100644
--- a/systests/qpid-systests-http-management/src/test/java/org/apache/qpid/tests/http/endtoend/message/MessageTest.java
+++ b/systests/qpid-systests-http-management/src/test/java/org/apache/qpid/tests/http/endtoend/message/MessageTest.java
@@ -153,8 +153,7 @@
@Test
public void getAcquiredMessage() throws Exception
{
-
- Connection connection = getConnection();
+ Connection connection = getConnectionBuilder().setSyncPublish(true).build();
try
{
Session session = connection.createSession(false, Session.CLIENT_ACKNOWLEDGE);
@@ -175,7 +174,7 @@
assertThat(message.get("deliveredToConsumerId"), is(nullValue()));
connection.start();
MessageConsumer consumer = session.createConsumer(queue);
- jmsMessage = consumer.receive(5000);
+ jmsMessage = consumer.receive(getReceiveTimeout());
assertThat(jmsMessage, is(notNullValue()));
messages = getHelper().postJson("queue/myqueue/getMessageInfo",
@@ -192,11 +191,8 @@
{
connection.close();
}
-
}
-
-
@Test
public void getJmsMapMessage() throws Exception
{
