You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by ra...@apache.org on 2007/10/22 15:45:12 UTC
svn commit: r587091 -
/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/perf/PerfConsumer.java
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) {