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 23:05:15 UTC
[qpid-broker-j] 04/04: 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 7.1.x
in repository https://gitbox.apache.org/repos/asf/qpid-broker-j.git
commit 99237c7c10e556afb4724736ac6e85e1f991a91e
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
(cherry picked from commit 55cc0b9e83a7e15c1b7aa990413b882836e11894)
---
.../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