From fcaa5ff88e5ad15469c54e29d8f0d87821ccf8e1 Mon Sep 17 00:00:00 2001 From: Keith Wall Date: Tue, 30 Dec 2014 07:48:12 +0000 Subject: NO-JIRA: [Java Tests] Prevent sporadic spurious failure of testUnidirectionalHeartbeating git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1648488 13f79535-47bb-0310-9956-ffa450edef68 --- .../systests/src/test/java/org/apache/qpid/client/HeartbeatTest.java | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) (limited to 'qpid/java') diff --git a/qpid/java/systests/src/test/java/org/apache/qpid/client/HeartbeatTest.java b/qpid/java/systests/src/test/java/org/apache/qpid/client/HeartbeatTest.java index 881a37a970..6612fedd35 100644 --- a/qpid/java/systests/src/test/java/org/apache/qpid/client/HeartbeatTest.java +++ b/qpid/java/systests/src/test/java/org/apache/qpid/client/HeartbeatTest.java @@ -120,12 +120,15 @@ public class HeartbeatTest extends QpidBrokerTestCase sendConn.setHeartbeatListener(sendListener); receiveConn.start(); + // Start the flow of messages to the consumer + consumer.receiveNoWait(); + for(int i = 0; i < 5; i++) { producer.send(senderSession.createTextMessage("Msg " + i)); Thread.sleep(500); assertNotNull("Expected to received message", consumer.receive(500)); - // Consumer does not ack the message in order to generate no bytes from consumer back to Broker + // Consumer does not ack the message in order that no bytes flow from consumer connection back to Broker } assertTrue("Too few heartbeats sent "+ receiveListener.getHeartbeatsSent() +" (expected at least 2)", receiveListener.getHeartbeatsSent()>=2); -- cgit v1.2.1