You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by ta...@apache.org on 2012/04/10 17:12:57 UTC
svn commit: r1311780 -
/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/kahadb/MessageDatabase.java
Author: tabish
Date: Tue Apr 10 15:12:56 2012
New Revision: 1311780
URL: http://svn.apache.org/viewvc?rev=1311780&view=rev
Log:
Remove unneeded tracing that was used for: https://issues.apache.org/jira/browse/AMQ-3775
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=1311780&r1=1311779&r2=1311780&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 Tue Apr 10 15:12:56 2012
@@ -1337,64 +1337,6 @@ public abstract class MessageDatabase ex
sd.messageIdIndex.clear(tx);
sd.locationIndex.clear(tx);
sd.orderIndex.clear(tx);
- } else {
-
- if (sd.subscriptionCache.size() == 1) {
-
- int messageIdCount = 0;
- TreeSet<Long> msgIdContents = new TreeSet<Long>();
- Iterator<Entry<String, Long>> iterator1 = sd.messageIdIndex.iterator(tx);
- while (iterator1.hasNext()) {
- Entry<String, Long> entry = iterator1.next();
- messageIdCount++;
- msgIdContents.add(entry.getValue());
- }
-
- int locationCount = 0;
- TreeSet<Long> locationContents = new TreeSet<Long>();
- Iterator<Entry<Location, Long>> iterator2 = sd.locationIndex.iterator(tx);
- while (iterator2.hasNext()) {
- Entry<Location, Long> entry = iterator2.next();
- locationCount++;
- locationContents.add(entry.getValue());
- }
-
- LOG.info("Size of sd.messageIdIndex = " + messageIdCount);
- LOG.info("Size of sd.locationIndex = " + locationCount);
- LOG.info("Size of sd.ackPositions = " + sd.ackPositions.size());
- LOG.info("Size of sd.messageReferences = " + sd.messageReferences.size());
-
- Iterator<Entry<String, SequenceSet>> iterator3 = sd.ackPositions.iterator(tx);
- while (iterator3.hasNext()) {
- Entry<String, SequenceSet> entry = iterator3.next();
- StringBuilder logEntry = new StringBuilder();
- logEntry.append("Subscription["+entry.getKey()+"] references: ");
- for (Long sequenceId : entry.getValue()) {
- logEntry.append(sequenceId + " ");
- }
- LOG.info(logEntry.toString());
- }
-
- StringBuilder msgIdLog = new StringBuilder();
- msgIdLog.append("sd.messageIdIndex contains [");
- for(Long sequenceId : msgIdContents) {
- msgIdLog.append(sequenceId + " ");
- }
- msgIdLog.append("]");
- LOG.info(msgIdLog.toString());
- StringBuilder locationLog = new StringBuilder();
- locationLog.append("sd.locationIndex contains [");
- for(Long sequenceId : locationContents) {
- locationLog.append(sequenceId + " ");
- }
- locationLog.append("]");
- LOG.info(locationLog.toString());
-
- LOG.info("Order index last default key: " + sd.orderIndex.lastDefaultKey);
- LOG.info("Order index last high key: " + sd.orderIndex.lastHighKey);
- LOG.info("Order index last low key: " + sd.orderIndex.lastLowKey);
- }
-
}
}
}