activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From chir...@apache.org
Subject svn commit: r633903 - in /activemq/trunk/activemq-optional/src/main/java/org/apache/activemq/benchmark: BenchmarkSupport.java Producer.java ProducerConsumer.java
Date Wed, 05 Mar 2008 16:14:43 GMT
Author: chirino
Date: Wed Mar  5 08:14:39 2008
New Revision: 633903

URL: http://svn.apache.org/viewvc?rev=633903&view=rev
Log:
Added some property accessors

Modified:
    activemq/trunk/activemq-optional/src/main/java/org/apache/activemq/benchmark/BenchmarkSupport.java
    activemq/trunk/activemq-optional/src/main/java/org/apache/activemq/benchmark/Producer.java
    activemq/trunk/activemq-optional/src/main/java/org/apache/activemq/benchmark/ProducerConsumer.java

Modified: activemq/trunk/activemq-optional/src/main/java/org/apache/activemq/benchmark/BenchmarkSupport.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-optional/src/main/java/org/apache/activemq/benchmark/BenchmarkSupport.java?rev=633903&r1=633902&r2=633903&view=diff
==============================================================================
--- activemq/trunk/activemq-optional/src/main/java/org/apache/activemq/benchmark/BenchmarkSupport.java
(original)
+++ activemq/trunk/activemq-optional/src/main/java/org/apache/activemq/benchmark/BenchmarkSupport.java
Wed Mar  5 08:14:39 2008
@@ -51,6 +51,7 @@
     private NumberFormat formatter = NumberFormat.getInstance();
     private AtomicInteger connectionCounter = new AtomicInteger(0);
     private IdGenerator idGenerator = new IdGenerator();
+    private boolean timerLoop;
 
     public BenchmarkSupport() {
     }
@@ -194,7 +195,7 @@
     }
 
     protected boolean useTimerLoop() {
-        return true;
+        return timerLoop;
     }
 
     protected Destination createDestination(Session session, String subject) throws JMSException
{
@@ -207,6 +208,14 @@
 
     protected void addResource(Object resource) {
         resources.add(resource);
+    }
+
+    public int getCounter() {
+        return counter;
+    }
+
+    public void setTimerLoop(boolean timerLoop) {
+        this.timerLoop = timerLoop;
     }
 
     protected static boolean parseBoolean(String text) {

Modified: activemq/trunk/activemq-optional/src/main/java/org/apache/activemq/benchmark/Producer.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-optional/src/main/java/org/apache/activemq/benchmark/Producer.java?rev=633903&r1=633902&r2=633903&view=diff
==============================================================================
--- activemq/trunk/activemq-optional/src/main/java/org/apache/activemq/benchmark/Producer.java
(original)
+++ activemq/trunk/activemq-optional/src/main/java/org/apache/activemq/benchmark/Producer.java
Wed Mar  5 08:14:39 2008
@@ -177,4 +177,12 @@
         in.close();
         return buffer.toString();
     }
+
+    public int getLoops() {
+        return loops;
+    }
+
+    public void setLoops(int loops) {
+        this.loops = loops;
+    }
 }

Modified: activemq/trunk/activemq-optional/src/main/java/org/apache/activemq/benchmark/ProducerConsumer.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-optional/src/main/java/org/apache/activemq/benchmark/ProducerConsumer.java?rev=633903&r1=633902&r2=633903&view=diff
==============================================================================
--- activemq/trunk/activemq-optional/src/main/java/org/apache/activemq/benchmark/ProducerConsumer.java
(original)
+++ activemq/trunk/activemq-optional/src/main/java/org/apache/activemq/benchmark/ProducerConsumer.java
Wed Mar  5 08:14:39 2008
@@ -77,4 +77,8 @@
     protected boolean useTimerLoop() {
         return false;
     }
+
+    public Consumer getConsumer() {
+        return consumer;
+    }
 }



Mime
View raw message