activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From rajdav...@apache.org
Subject svn commit: r586025 - in /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/perf: InactiveDurableTopicTest.java PerfConsumer.java SimpleTopicTest.java
Date Thu, 18 Oct 2007 16:22:08 GMT
Author: rajdavies
Date: Thu Oct 18 09:22:07 2007
New Revision: 586025

URL: http://svn.apache.org/viewvc?rev=586025&view=rev
Log:
Check for duplicates

Modified:
    activemq/trunk/activemq-core/src/test/java/org/apache/activemq/perf/InactiveDurableTopicTest.java
    activemq/trunk/activemq-core/src/test/java/org/apache/activemq/perf/PerfConsumer.java
    activemq/trunk/activemq-core/src/test/java/org/apache/activemq/perf/SimpleTopicTest.java

Modified: activemq/trunk/activemq-core/src/test/java/org/apache/activemq/perf/InactiveDurableTopicTest.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/perf/InactiveDurableTopicTest.java?rev=586025&r1=586024&r2=586025&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/test/java/org/apache/activemq/perf/InactiveDurableTopicTest.java
(original)
+++ activemq/trunk/activemq-core/src/test/java/org/apache/activemq/perf/InactiveDurableTopicTest.java
Thu Oct 18 09:22:07 2007
@@ -40,7 +40,7 @@
 public class InactiveDurableTopicTest extends TestCase {
     private static final transient Log LOG = LogFactory.getLog(InactiveDurableTopicTest.class);
 
-    private static final int MESSAGE_COUNT = 1000000;
+    private static final int MESSAGE_COUNT = 2000;
     private static final String DEFAULT_PASSWORD = "";
     private static final String USERNAME = "testuser";
     private static final String CLIENTID = "mytestclient";

Modified: activemq/trunk/activemq-core/src/test/java/org/apache/activemq/perf/PerfConsumer.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/perf/PerfConsumer.java?rev=586025&r1=586024&r2=586025&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/test/java/org/apache/activemq/perf/PerfConsumer.java
(original)
+++ activemq/trunk/activemq-core/src/test/java/org/apache/activemq/perf/PerfConsumer.java
Thu Oct 18 09:22:07 2007
@@ -26,13 +26,20 @@
 import javax.jms.Session;
 import javax.jms.Topic;
 
+import org.apache.activemq.ActiveMQConnection;
+import org.apache.activemq.ActiveMQMessageAudit;
+import org.apache.commons.logging.Log;
+import org.apache.commons.logging.LogFactory;
+
 /**
  * @version $Revision: 1.3 $
  */
 public class PerfConsumer implements MessageListener {
+    private static final Log LOG = LogFactory.getLog(PerfConsumer.class);
     protected Connection connection;
     protected MessageConsumer consumer;
     protected long sleepDuration;
+    protected ActiveMQMessageAudit audit = new ActiveMQMessageAudit(16 * 1024,20);
 
     protected PerfRate rate = new PerfRate();
 
@@ -71,6 +78,14 @@
 
     public void onMessage(Message msg) {
         rate.increment();
+        try {
+            if (this.audit.isDuplicateMessage(msg)){
+                LOG.error("Duplicate Message!" + msg);
+            }
+        } catch (JMSException e1) {
+            // TODO Auto-generated catch block
+            e1.printStackTrace();
+        }
         try {
             if (sleepDuration != 0) {
                 Thread.sleep(sleepDuration);

Modified: activemq/trunk/activemq-core/src/test/java/org/apache/activemq/perf/SimpleTopicTest.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/perf/SimpleTopicTest.java?rev=586025&r1=586024&r2=586025&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/test/java/org/apache/activemq/perf/SimpleTopicTest.java
(original)
+++ activemq/trunk/activemq-core/src/test/java/org/apache/activemq/perf/SimpleTopicTest.java
Thu Oct 18 09:22:07 2007
@@ -37,22 +37,22 @@
     protected BrokerService broker;
     // protected String
     // bindAddress="tcp://localhost:61616?wireFormat.cacheEnabled=true&wireFormat.tightEncodingEnabled=true&jms.useAsyncSend=false";
-    // protected String bindAddress="tcp://localhost:61616";
-    protected String bindAddress = "tcp://localhost:61616";
-    // protected String bindAddress="vm://localhost?marshal=true";
-    // protected String bindAddress="vm://localhost";
+    //protected String bindAddress="tcp://localhost:61616";
+    //protected String bindAddress = "tcp://localhost:61616";
+    //protected String bindAddress="vm://localhost?marshal=true";
+    protected String bindAddress="vm://localhost";
     protected PerfProducer[] producers;
     protected PerfConsumer[] consumers;
     protected String destinationName = getClass().getName();
     protected int samepleCount = 10;
-    protected long sampleInternal = 1000;
-    protected int numberOfConsumers = 10;
-    protected int numberofProducers = 1;
+    protected long sampleInternal = 10000;
+    protected int numberOfConsumers = 1;
+    protected int numberofProducers = 2;
     protected int playloadSize = 1024;
     protected byte[] array;
     protected ConnectionFactory factory;
     protected Destination destination;
-    protected long consumerSleepDuration;
+    protected long consumerSleepDuration=0;
 
     /**
      * Sets up a test where the producer and consumer have their own connection.
@@ -127,6 +127,7 @@
     protected void configureBroker(BrokerService answer) throws Exception {
         answer.addConnector(bindAddress);
         answer.setDeleteAllMessagesOnStartup(true);
+        answer.setUseShutdownHook(false);
     }
 
     protected ActiveMQConnectionFactory createConnectionFactory() throws Exception {
@@ -163,7 +164,7 @@
             totalCount += rate.getTotalCount();
         }
         int avgRate = totalRate / producers.length;
-        LOG.info("Avg producer rate = " + avgRate + " msg/sec | Total rate = " + totalRate
+ ", sent = " + totalCount);
+        System.out.println("Avg producer rate = " + avgRate + " msg/sec | Total rate = "
+ totalRate + ", sent = " + totalCount);
     }
 
     protected void dumpConsumerRate() {
@@ -176,7 +177,7 @@
         }
         if (consumers != null && consumers.length > 0) {
             int avgRate = totalRate / consumers.length;
-            LOG.info("Avg consumer rate = " + avgRate + " msg/sec | Total rate = " + totalRate
+ ", received = " + totalCount);
+            System.out.println("Avg consumer rate = " + avgRate + " msg/sec | Total rate
= " + totalRate + ", received = " + totalCount);
         }
     }
 }



Mime
View raw message