activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From gtu...@apache.org
Subject svn commit: r990158 - /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/kahadb/MessageDatabase.java
Date Fri, 27 Aug 2010 14:08:40 GMT
Author: gtully
Date: Fri Aug 27 14:08:40 2010
New Revision: 990158

URL: http://svn.apache.org/viewvc?rev=990158&view=rev
Log:
record the destination of a dup in the warn message, helps diagnose

Modified:
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/kahadb/MessageDatabase.java

Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/kahadb/MessageDatabase.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/kahadb/MessageDatabase.java?rev=990158&r1=990157&r2=990158&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/kahadb/MessageDatabase.java
(original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/kahadb/MessageDatabase.java
Fri Aug 27 14:08:40 2010
@@ -995,7 +995,7 @@ public class MessageDatabase extends Ser
                 // If the message ID as indexed, then the broker asked us to
                 // store a DUP
                 // message. Bad BOY! Don't do it, and log a warning.
-                LOG.warn("Duplicate message add attempt rejected. Message id: " + command.getMessageId());
+                LOG.warn("Duplicate message add attempt rejected. Destination: " + command.getDestination().getName()
+ ", Message id: " + command.getMessageId());
                 // TODO: consider just rolling back the tx.
                 sd.messageIdIndex.put(tx, command.getMessageId(), previous);
                 sd.locationIndex.remove(tx, location);



Mime
View raw message