activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From rajdav...@apache.org
Subject svn commit: r587091 - /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/perf/PerfConsumer.java
Date Mon, 22 Oct 2007 13:45:12 GMT
Author: rajdavies
Date: Mon Oct 22 06:45:12 2007
New Revision: 587091

URL: http://svn.apache.org/viewvc?rev=587091&view=rev
Log:
check for message order 

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

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=587091&r1=587090&r2=587091&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
Mon Oct 22 06:45:12 2007
@@ -79,7 +79,10 @@
     public void onMessage(Message msg) {
         rate.increment();
         try {
-            if (this.audit.isDuplicateMessage(msg)){
+            if (!this.audit.isInOrder(msg.getJMSMessageID())) {
+                LOG.error("Message out of order!!" + msg);
+            }
+            if (this.audit.isDuplicate(msg)){
                 LOG.error("Duplicate Message!" + msg);
             }
         } catch (JMSException e1) {



Mime
View raw message