diff options
| -rw-r--r-- | qpid/java/perftests/src/main/java/org/apache/qpid/client/perf/MessageConsumerTest.java | 1 | ||||
| -rw-r--r-- | qpid/java/perftests/src/main/java/org/apache/qpid/client/perf/MessageProducerTest.java | 1 |
2 files changed, 2 insertions, 0 deletions
diff --git a/qpid/java/perftests/src/main/java/org/apache/qpid/client/perf/MessageConsumerTest.java b/qpid/java/perftests/src/main/java/org/apache/qpid/client/perf/MessageConsumerTest.java index 4d6923f0dd..e220aec9e1 100644 --- a/qpid/java/perftests/src/main/java/org/apache/qpid/client/perf/MessageConsumerTest.java +++ b/qpid/java/perftests/src/main/java/org/apache/qpid/client/perf/MessageConsumerTest.java @@ -68,6 +68,7 @@ public class MessageConsumerTest extends Options implements Runnable { boolean run = true; _startTime = System.currentTimeMillis(); + runReaper(false); try { while(run) diff --git a/qpid/java/perftests/src/main/java/org/apache/qpid/client/perf/MessageProducerTest.java b/qpid/java/perftests/src/main/java/org/apache/qpid/client/perf/MessageProducerTest.java index b0caa45845..794031f346 100644 --- a/qpid/java/perftests/src/main/java/org/apache/qpid/client/perf/MessageProducerTest.java +++ b/qpid/java/perftests/src/main/java/org/apache/qpid/client/perf/MessageProducerTest.java @@ -65,6 +65,7 @@ public class MessageProducerTest extends Options implements Runnable { boolean run = true; _startTime = System.currentTimeMillis(); + runReaper(false); try { while(run) |