[jboss-cvs] JBoss Messaging SVN: r4347 - in trunk: examples/jms/src/org/jboss/jms/example and 1 other directories.

[jboss-cvs-commits at lists.jboss.org]

Author: timfox
Date: 2008-05-29 12:47:02 -0400 (Thu, 29 May 2008)
New Revision: 4347

Modified:
   trunk/examples/jms/build.xml
   trunk/examples/jms/src/org/jboss/jms/example/PerfExample.java
   trunk/src/main/org/jboss/messaging/core/client/impl/ClientProducerImpl.java
Log:
More tweaks


Modified: trunk/examples/jms/build.xml
===================================================================
--- trunk/examples/jms/build.xml	2008-05-29 16:42:41 UTC (rev 4346)
+++ trunk/examples/jms/build.xml	2008-05-29 16:47:02 UTC (rev 4347)
@@ -128,7 +128,7 @@
 * parameter            current (default)                 description                     
 * ---------            -----------------                 -----------                     
 * message.count        ${message.count} (200000)         number of messages    
-* message.size         ${message.size} (1000)            size of message in bytes      	
+* message.size         ${message.size} (1024)            size of message in bytes      	
 * message.warmup.count ${message.warmup.count} (10000)   number of messages to warm up   
 * delivery.mode        ${delivery.mode} (NON_PERSISTENT) PERSISTENT/NON_PERSISTENT       
 * sess.trans           ${sess.trans} (false)             Is session transacted           

Modified: trunk/examples/jms/src/org/jboss/jms/example/PerfExample.java
===================================================================
--- trunk/examples/jms/src/org/jboss/jms/example/PerfExample.java	2008-05-29 16:42:41 UTC (rev 4346)
+++ trunk/examples/jms/src/org/jboss/jms/example/PerfExample.java	2008-05-29 16:47:02 UTC (rev 4347)
@@ -170,7 +170,7 @@
       byte[] payload = new byte[messageSize];
       bytesMessage.writeBytes(payload);
       
-      final int modulo = 1000;
+      final int modulo = 2000;
       
       TokenBucketLimiter tbl = throttleRate != -1 ? new TokenBucketLimiter(throttleRate, false): null;
 
@@ -282,7 +282,7 @@
          this.countDownLatch = countDownLatch;
          this.perfParams = perfParams;
          warmingUp = perfParams.getNoOfWarmupMessages() > 0;
-         this.modulo = 1000;
+         this.modulo = 2000;
       }
 
       public void onMessage(final Message message)

Modified: trunk/src/main/org/jboss/messaging/core/client/impl/ClientProducerImpl.java
===================================================================
--- trunk/src/main/org/jboss/messaging/core/client/impl/ClientProducerImpl.java	2008-05-29 16:42:41 UTC (rev 4346)
+++ trunk/src/main/org/jboss/messaging/core/client/impl/ClientProducerImpl.java	2008-05-29 16:47:02 UTC (rev 4347)
@@ -162,7 +162,7 @@
       ProducerSendMessage message = new ProducerSendMessage(msg);
          		
    	if (sendBlocking)
-   	{
+   	{   	   
    	   remotingConnection.sendBlocking(serverTargetID, session.getServerTargetID(), message);
    	}
    	else