diff options
| author | Keith Wall <kwall@apache.org> | 2014-12-30 07:48:12 +0000 |
|---|---|---|
| committer | Keith Wall <kwall@apache.org> | 2014-12-30 07:48:12 +0000 |
| commit | fcaa5ff88e5ad15469c54e29d8f0d87821ccf8e1 (patch) | |
| tree | b59abbf8f01191ff4246ae8be3ea6fe36499359a /qpid/java | |
| parent | 6c07f50f9e9a3f1c620a4ea7dee4f117507261d6 (diff) | |
| download | qpid-python-fcaa5ff88e5ad15469c54e29d8f0d87821ccf8e1.tar.gz | |
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
Diffstat (limited to 'qpid/java')
| -rw-r--r-- | qpid/java/systests/src/test/java/org/apache/qpid/client/HeartbeatTest.java | 5 |
1 files changed, 4 insertions, 1 deletions
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); |