You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by ra...@apache.org on 2007/06/25 14:49:01 UTC

svn commit: r550476 - in /activemq/trunk/assembly/src/test/java/org/apache/activemq/benchmark: BenchmarkSupport.java Producer.java

Author: rajdavies
Date: Mon Jun 25 05:49:00 2007
New Revision: 550476

URL: http://svn.apache.org/viewvc?view=rev&rev=550476
Log:
apply patch http://issues.apache.org/activemq/browse/AMQ-1293

Modified:
    activemq/trunk/assembly/src/test/java/org/apache/activemq/benchmark/BenchmarkSupport.java
    activemq/trunk/assembly/src/test/java/org/apache/activemq/benchmark/Producer.java

Modified: activemq/trunk/assembly/src/test/java/org/apache/activemq/benchmark/BenchmarkSupport.java
URL: http://svn.apache.org/viewvc/activemq/trunk/assembly/src/test/java/org/apache/activemq/benchmark/BenchmarkSupport.java?view=diff&rev=550476&r1=550475&r2=550476
==============================================================================
--- activemq/trunk/assembly/src/test/java/org/apache/activemq/benchmark/BenchmarkSupport.java (original)
+++ activemq/trunk/assembly/src/test/java/org/apache/activemq/benchmark/BenchmarkSupport.java Mon Jun 25 05:49:00 2007
@@ -184,7 +184,7 @@
                 times++;
             }
             if (times > 0) {
-                average = total / times;
+                average = total / (double) times;
             }
 
             long oldtime = time;

Modified: activemq/trunk/assembly/src/test/java/org/apache/activemq/benchmark/Producer.java
URL: http://svn.apache.org/viewvc/activemq/trunk/assembly/src/test/java/org/apache/activemq/benchmark/Producer.java?view=diff&rev=550476&r1=550475&r2=550476
==============================================================================
--- activemq/trunk/assembly/src/test/java/org/apache/activemq/benchmark/Producer.java (original)
+++ activemq/trunk/assembly/src/test/java/org/apache/activemq/benchmark/Producer.java Mon Jun 25 05:49:00 2007
@@ -178,6 +178,7 @@
             buffer.append(line);
             buffer.append(File.separator);
         }
+        in.close();
         return buffer.toString();
     }
 }