You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by or...@apache.org on 2019/11/23 22:41:25 UTC
[qpid-broker-j] branch master updated: QPID-8373: Modify test to
use synchrnous publishing and preconfigured receive interval
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 <or...@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-unsubscribe@qpid.apache.org
For additional commands, e-mail: commits-help@qpid.apache.org