[qpid-broker-j] branch master updated: QPID-8373: Modify test to use synchrnous publishing and preconfigured receive interval

[orudyy]

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


The following commit(s) were added to refs/heads/master by this push:
     new 55cc0b9  QPID-8373: Modify test to use synchrnous publishing and 
preconfigured receive interval
55cc0b9 is described below

commit 55cc0b9e83a7e15c1b7aa990413b882836e11894
Author: Alex Rudyy <oru...@apache.org>
AuthorDate: Sat Nov 23 22:41:31 2019 +0000

    QPID-8373: Modify test to use synchrnous publishing and preconfigured 
receive interval
---
 .../org/apache/qpid/tests/http/endtoend/message/MessageTest.java  | 8 ++------
 1 file changed, 2 insertions(+), 6 deletions(-)

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 @@ public class MessageTest extends HttpTestBase
     @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 @@ public class MessageTest extends HttpTestBase
             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 @@ public class MessageTest extends HttpTestBase
         {
             connection.close();
         }
-
     }
 
-
-
     @Test
     public void getJmsMapMessage() throws Exception
     {


---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@qpid.apache.org
For additional commands, e-mail: commits-h...@qpid.apache.org