From ff5e7e76264af13db020e627bdf81e23e9b4fbea Mon Sep 17 00:00:00 2001 From: "Timothy A. Bish" Date: Tue, 10 Apr 2012 15:12:56 +0000 Subject: [PATCH] Remove unneeded tracing that was used for: https://issues.apache.org/jira/browse/AMQ-3775 git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1311780 13f79535-47bb-0310-9956-ffa450edef68 --- .../store/kahadb/MessageDatabase.java | 58 ------------------- 1 file changed, 58 deletions(-) diff --git a/activemq-core/src/main/java/org/apache/activemq/store/kahadb/MessageDatabase.java b/activemq-core/src/main/java/org/apache/activemq/store/kahadb/MessageDatabase.java index 1fbea759a0..39f78d3e9d 100644 --- a/activemq-core/src/main/java/org/apache/activemq/store/kahadb/MessageDatabase.java +++ b/activemq-core/src/main/java/org/apache/activemq/store/kahadb/MessageDatabase.java @@ -1337,64 +1337,6 @@ public abstract class MessageDatabase extends ServiceSupport implements BrokerSe sd.messageIdIndex.clear(tx); sd.locationIndex.clear(tx); sd.orderIndex.clear(tx); - } else { - - if (sd.subscriptionCache.size() == 1) { - - int messageIdCount = 0; - TreeSet msgIdContents = new TreeSet(); - Iterator> iterator1 = sd.messageIdIndex.iterator(tx); - while (iterator1.hasNext()) { - Entry entry = iterator1.next(); - messageIdCount++; - msgIdContents.add(entry.getValue()); - } - - int locationCount = 0; - TreeSet locationContents = new TreeSet(); - Iterator> iterator2 = sd.locationIndex.iterator(tx); - while (iterator2.hasNext()) { - Entry 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> iterator3 = sd.ackPositions.iterator(tx); - while (iterator3.hasNext()) { - Entry 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); - } - } } }