[jboss-cvs] JBoss Messaging SVN: r4139 - projects/jms-perf/src/java/jms.

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

Author: jmesnil
Date: 2008-04-30 08:54:07 -0400 (Wed, 30 Apr 2008)
New Revision: 4139

Modified:
   projects/jms-perf/src/java/jms/ActiveMQPerfTest.java
   projects/jms-perf/src/java/jms/JBMessagingPerfTest.java
   projects/jms-perf/src/java/jms/QpidPerfTest.java
Log:
added testAutoAck_Persistent & testClientAck_Persistent

Modified: projects/jms-perf/src/java/jms/ActiveMQPerfTest.java
===================================================================
--- projects/jms-perf/src/java/jms/ActiveMQPerfTest.java	2008-04-30 12:32:56 UTC (rev 4138)
+++ projects/jms-perf/src/java/jms/ActiveMQPerfTest.java	2008-04-30 12:54:07 UTC (rev 4139)
@@ -27,18 +27,26 @@
    {
       Properties props = getActiveMQProperties();
       sendAndReceiveManyMessages(props, Session.AUTO_ACKNOWLEDGE, DeliveryMode.NON_PERSISTENT);
-      
-      System.out.println("ActiveMQ [OK]");
    }
 
    public void testClientAck_NonPersistent() throws Exception
    {
       Properties props = getActiveMQProperties();
       sendAndReceiveManyMessages(props, Session.CLIENT_ACKNOWLEDGE, DeliveryMode.NON_PERSISTENT);
-      
-      System.out.println("ActiveMQ [OK]");
    }
 
+   public void testAutoAck_Persistent() throws Exception
+   {
+      Properties props = getActiveMQProperties();
+      sendAndReceiveManyMessages(props, Session.AUTO_ACKNOWLEDGE, DeliveryMode.PERSISTENT);
+   }
+
+   public void testClientAck_Persistent() throws Exception
+   {
+      Properties props = getActiveMQProperties();
+      sendAndReceiveManyMessages(props, Session.CLIENT_ACKNOWLEDGE, DeliveryMode.PERSISTENT);
+   }
+
    // Package protected ---------------------------------------------
 
    // Protected -----------------------------------------------------

Modified: projects/jms-perf/src/java/jms/JBMessagingPerfTest.java
===================================================================
--- projects/jms-perf/src/java/jms/JBMessagingPerfTest.java	2008-04-30 12:32:56 UTC (rev 4138)
+++ projects/jms-perf/src/java/jms/JBMessagingPerfTest.java	2008-04-30 12:54:07 UTC (rev 4139)
@@ -27,18 +27,26 @@
    {
       Properties props = getJBMessagingProperties();
       sendAndReceiveManyMessages(props, Session.AUTO_ACKNOWLEDGE, DeliveryMode.NON_PERSISTENT);
-      
-      System.out.println("JBMessaging [OK]");
    }
 
    public void testClientAck_NonPersistent() throws Exception
    {
       Properties props = getJBMessagingProperties();
       sendAndReceiveManyMessages(props, Session.CLIENT_ACKNOWLEDGE, DeliveryMode.NON_PERSISTENT);
-      
-      System.out.println("JBMessaging [OK]");
    }
 
+   public void testAutoAck_Persistent() throws Exception
+   {
+      Properties props = getJBMessagingProperties();
+      sendAndReceiveManyMessages(props, Session.AUTO_ACKNOWLEDGE, DeliveryMode.PERSISTENT);
+   }
+
+   public void testClientAck_Persistent() throws Exception
+   {
+      Properties props = getJBMessagingProperties();
+      sendAndReceiveManyMessages(props, Session.CLIENT_ACKNOWLEDGE, DeliveryMode.PERSISTENT);
+   }
+
    // Package protected ---------------------------------------------
 
    // Protected -----------------------------------------------------

Modified: projects/jms-perf/src/java/jms/QpidPerfTest.java
===================================================================
--- projects/jms-perf/src/java/jms/QpidPerfTest.java	2008-04-30 12:32:56 UTC (rev 4138)
+++ projects/jms-perf/src/java/jms/QpidPerfTest.java	2008-04-30 12:54:07 UTC (rev 4139)
@@ -27,18 +27,26 @@
    {
       Properties props = getQpidProperties();
       sendAndReceiveManyMessages(props, Session.AUTO_ACKNOWLEDGE, DeliveryMode.NON_PERSISTENT);
-      
-      System.out.println("Qpid [OK]");
    }
 
    public void testClientAck_NonPersistent() throws Exception
    {
       Properties props = getQpidProperties();
-      sendAndReceiveManyMessages(props, Session.CLIENT_ACKNOWLEDGE, DeliveryMode.NON_PERSISTENT);
-      
-      System.out.println("Qpid [OK]");
+      sendAndReceiveManyMessages(props, Session.CLIENT_ACKNOWLEDGE, DeliveryMode.NON_PERSISTENT);      
    }
 
+   public void testAutoAck_Persistent() throws Exception
+   {
+      Properties props = getQpidProperties();
+      sendAndReceiveManyMessages(props, Session.AUTO_ACKNOWLEDGE, DeliveryMode.PERSISTENT);
+   }
+
+   public void testClientAck_Persistent() throws Exception
+   {
+      Properties props = getQpidProperties();
+      sendAndReceiveManyMessages(props, Session.CLIENT_ACKNOWLEDGE, DeliveryMode.PERSISTENT);
+   }
+   
    // Package protected ---------------------------------------------
 
    // Protected -----------------------------------------------------