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

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

Author: timfox
Date: 2008-05-14 10:25:01 -0400 (Wed, 14 May 2008)
New Revision: 4192

Modified:
   trunk/examples/jms/build.xml
   trunk/examples/jms/src/org/jboss/jms/example/PerfExample.java
Log:
Tweaked example


Modified: trunk/examples/jms/build.xml
===================================================================
--- trunk/examples/jms/build.xml	2008-05-14 13:35:05 UTC (rev 4191)
+++ trunk/examples/jms/build.xml	2008-05-14 14:25:01 UTC (rev 4192)
@@ -41,7 +41,7 @@
    <property name="build.dir" value="build"/>
 
    <!--perf props-->
-   <property name="message.count" value="10000"/>
+   <property name="message.count" value="200000"/>
    <property name="delivery.mode" value="NON_PERSISTENT"/>
    <property name="sample.period" value="1"/>
 

Modified: trunk/examples/jms/src/org/jboss/jms/example/PerfExample.java
===================================================================
--- trunk/examples/jms/src/org/jboss/jms/example/PerfExample.java	2008-05-14 13:35:05 UTC (rev 4191)
+++ trunk/examples/jms/src/org/jboss/jms/example/PerfExample.java	2008-05-14 14:25:01 UTC (rev 4192)
@@ -68,7 +68,7 @@
       queue = (Queue) initialContext.lookup("/queue/testPerfQueue");
       ConnectionFactory cf = (ConnectionFactory) initialContext.lookup("/ConnectionFactory");
       connection = cf.createConnection();
-      session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
+      session = connection.createSession(false, Session.DUPS_OK_ACKNOWLEDGE);
    }
    
    public void runSender(int noOfMessage, int deliveryMode, long samplePeriod)
@@ -77,6 +77,8 @@
       {
          init();
          MessageProducer producer = session.createProducer(queue);
+         producer.setDisableMessageID(true);
+         producer.setDisableMessageTimestamp(true);
          producer.setDeliveryMode(deliveryMode);
          ObjectMessage m = session.createObjectMessage();
          PerfParams perfParams = new PerfParams();
@@ -86,10 +88,12 @@
          m.setObject(perfParams);
          producer.send(m);
          scheduler.scheduleAtFixedRate(command, perfParams.getSamplePeriod(), perfParams.getSamplePeriod(), TimeUnit.SECONDS);
+         BytesMessage bytesMessage = session.createBytesMessage();
+         byte[] payload = new byte[1024];
+         bytesMessage.writeBytes(payload);
          for (int i = 1; i <= noOfMessage; i++)
          {
-            TextMessage textMessage = session.createTextMessage("" + i);
-            producer.send(textMessage);
+            producer.send(bytesMessage);
             messageCount++;
          }
          scheduler.shutdownNow();
@@ -190,31 +194,13 @@
          }
          else
          {
-            try
+            BytesMessage bm = (BytesMessage) message;
+            messageCount++;               
+            if (messageCount == params.getNoOfMessagesToSend())
             {
-               TextMessage m = (TextMessage) message;
-               messageCount++;
-               int count = Integer.parseInt(m.getText());
-               if (count == params.getNoOfMessagesToSend())
-               {
-                  countDownLatch.countDown();
-                 /* try
-                  {
-                     Thread.sleep(params.getSamplePeriod());
-                  }
-                  catch (InterruptedException e)
-                  {
-                     //ignore
-                  }*/
-                  scheduler.shutdownNow();
-                  log.info("average " +  command.getAverage() + " per " + (params.getSamplePeriod()/1000) + " secs" );
-               }
-            }
-            catch (JMSException e)
-            {
-               log.info(e);
                countDownLatch.countDown();
                scheduler.shutdownNow();
+               log.info("average " +  command.getAverage() + " per " + (params.getSamplePeriod()/1000) + " secs" );
             }
          }
       }