activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From chir...@apache.org
Subject svn commit: r745885 - in /activemq/sandbox/activemq-flow/src/test/java/org/apache/activemq/flow: MockBrokerTest.java RemoteProducer.java
Date Thu, 19 Feb 2009 14:37:23 GMT
Author: chirino
Date: Thu Feb 19 14:37:23 2009
New Revision: 745885

URL: http://svn.apache.org/viewvc?rev=745885&view=rev
Log:
Made payload generation more efficent.

Modified:
    activemq/sandbox/activemq-flow/src/test/java/org/apache/activemq/flow/MockBrokerTest.java
    activemq/sandbox/activemq-flow/src/test/java/org/apache/activemq/flow/RemoteProducer.java

Modified: activemq/sandbox/activemq-flow/src/test/java/org/apache/activemq/flow/MockBrokerTest.java
URL: http://svn.apache.org/viewvc/activemq/sandbox/activemq-flow/src/test/java/org/apache/activemq/flow/MockBrokerTest.java?rev=745885&r1=745884&r2=745885&view=diff
==============================================================================
--- activemq/sandbox/activemq-flow/src/test/java/org/apache/activemq/flow/MockBrokerTest.java
(original)
+++ activemq/sandbox/activemq-flow/src/test/java/org/apache/activemq/flow/MockBrokerTest.java
Thu Feb 19 14:37:23 2009
@@ -35,7 +35,7 @@
 
 public class MockBrokerTest extends TestCase {
 
-    protected static final int PERFORMANCE_SAMPLES = 30000;
+    protected static final int PERFORMANCE_SAMPLES = 3;
 
     protected static final int IO_WORK_AMOUNT = 0;
     protected static final int FANIN_COUNT = 10;
@@ -51,7 +51,7 @@
     protected boolean ptp = false;
 
     // Set to use tcp IO
-    protected boolean tcp = true;
+    protected boolean tcp = false;
     // set to force marshalling even in the NON tcp case.
     protected boolean forceMarshalling = false;
     

Modified: activemq/sandbox/activemq-flow/src/test/java/org/apache/activemq/flow/RemoteProducer.java
URL: http://svn.apache.org/viewvc/activemq/sandbox/activemq-flow/src/test/java/org/apache/activemq/flow/RemoteProducer.java?rev=745885&r1=745884&r2=745885&view=diff
==============================================================================
--- activemq/sandbox/activemq-flow/src/test/java/org/apache/activemq/flow/RemoteProducer.java
(original)
+++ activemq/sandbox/activemq-flow/src/test/java/org/apache/activemq/flow/RemoteProducer.java
Thu Feb 19 14:37:23 2009
@@ -14,7 +14,6 @@
 
 public class RemoteProducer extends RemoteConnection implements Dispatchable, FlowUnblockListener<Message>{
 
-    private static final int FILLER_SIZE = 100;
 
     private final MetricCounter rate = new MetricCounter();
 
@@ -30,14 +29,17 @@
     private DispatchContext dispatchContext;
 
     private String filler;
+    private int payloadSize = 20;
     
     public void start() throws Exception {
         
-        StringBuilder sb = new StringBuilder(FILLER_SIZE);
-        for( int i=0; i < FILLER_SIZE; ++i) {
-            sb.append('a'+(i%26));
+        if( payloadSize>0 ) {
+            StringBuilder sb = new StringBuilder(payloadSize);
+            for( int i=0; i < payloadSize; ++i) {
+                sb.append((char)('a'+(i%26)));
+            }
+            filler = sb.toString();
         }
-        filler = sb.toString();
         
         rate.name("Producer " + name + " Rate");
         totalProducerRate.add(rate);
@@ -104,7 +106,22 @@
 	}
 
     private String createPayload() {
-        return name + ++counter+filler;
+        if( payloadSize>=0 ) {
+            StringBuilder sb = new StringBuilder(payloadSize);
+            sb.append(name);
+            sb.append(':');
+            sb.append(++counter);
+            sb.append(':');
+            int length = sb.length();
+            if( length <= payloadSize ) {
+                sb.append(filler.subSequence(0, payloadSize-length));
+                return sb.toString();
+            } else {
+               return sb.substring(0, payloadSize); 
+            }
+        } else {
+            return name+":"+(++counter);
+        }
     }
 	
 	public void setName(String name) {
@@ -170,5 +187,13 @@
     public MetricCounter getRate() {
         return rate;
     }
+
+    public int getPayloadSize() {
+        return payloadSize;
+    }
+
+    public void setPayloadSize(int messageSize) {
+        this.payloadSize = messageSize;
+    }
 }
 



Mime
View raw message