mirror of https://github.com/apache/activemq.git
clear the list after the sleep so that any left over messages are drained.
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@387632 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
parent
12cea50f15
commit
a255628557
|
@ -103,9 +103,10 @@ public class JmsSendReceiveTestSupport extends TestSupport implements MessageLis
|
||||||
* @throws Exception
|
* @throws Exception
|
||||||
*/
|
*/
|
||||||
public void testSendReceive() throws Exception {
|
public void testSendReceive() throws Exception {
|
||||||
|
|
||||||
|
Thread.sleep(1000);
|
||||||
messages.clear();
|
messages.clear();
|
||||||
|
|
||||||
Thread.sleep(1000);
|
|
||||||
for (int i = 0; i < data.length; i++) {
|
for (int i = 0; i < data.length; i++) {
|
||||||
Message message = session.createTextMessage(data[i]);
|
Message message = session.createTextMessage(data[i]);
|
||||||
if (verbose) {
|
if (verbose) {
|
||||||
|
|
Loading…
Reference in New Issue