From c8b8fdde4f7611ec2285897b0d0b2d78fcb81fbd Mon Sep 17 00:00:00 2001
From: James Strachan <jstrachan@apache.org>
Date: Mon, 13 Mar 2006 08:42:42 +0000
Subject: [PATCH] updated timers to ensure that the test runs even on slow
 machines

git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@385467 13f79535-47bb-0310-9956-ffa450edef68
---
 .../org/apache/activemq/LargeStreamletTest.java   | 15 ++++++++++++---
 1 file changed, 12 insertions(+), 3 deletions(-)

diff --git a/activemq-core/src/test/java/org/apache/activemq/LargeStreamletTest.java b/activemq-core/src/test/java/org/apache/activemq/LargeStreamletTest.java
index 99c1abfe30..35ec4922c7 100644
--- a/activemq-core/src/test/java/org/apache/activemq/LargeStreamletTest.java
+++ b/activemq-core/src/test/java/org/apache/activemq/LargeStreamletTest.java
@@ -47,6 +47,10 @@ public final class LargeStreamletTest extends TestCase {
 
     private AtomicBoolean stopThreads = new AtomicBoolean(false);
 
+    protected Exception writerException;
+
+    protected Exception readerException;
+
     public void testStreamlets() throws Exception {
         final ActiveMQConnectionFactory factory = new ActiveMQConnectionFactory(
                 BROKER_URL);
@@ -77,6 +81,7 @@ public final class LargeStreamletTest extends TestCase {
                                 inputStream.close();
                             }
                         } catch (Exception e) {
+                            readerException  = e;
                             e.printStackTrace();
                         } finally {
                             System.err
@@ -105,6 +110,7 @@ public final class LargeStreamletTest extends TestCase {
                                 outputStream.close();
                             }
                         } catch (Exception e) {
+                            writerException = e;
                             e.printStackTrace();
                         } finally {
                             System.err.println(totalWritten
@@ -116,11 +122,14 @@ public final class LargeStreamletTest extends TestCase {
                 readerThread.start();
                 writerThread.start();
 
-                readerThread.join(30*1000);
-                writerThread.join(10);
+                writerThread.join(60 * 1000);
+                readerThread.join(60 * 1000);
                 
                 stopThreads.set(true);
-                                
+
+                assertTrue("Should not have received a reader exception", readerException == null);
+                assertTrue("Should not have received a writer exception", writerException == null);
+                
                 Assert.assertEquals("Not all messages accounted for", 
                         totalWritten, totalRead);