Apache
/
activemq
mirror of https://github.com/apache/activemq.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

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
This commit is contained in:
Timothy A. Bish 2012-04-10 15:12:56 +00:00
parent 34af42f444
commit ff5e7e7626
1 changed files with 0 additions and 58 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

58
activemq-core/src/main/java/org/apache/activemq/store/kahadb/MessageDatabase.java
View File

@ -1337,64 +1337,6 @@ public abstract class MessageDatabase extends ServiceSupport implements BrokerSe
sd.messageIdIndex.clear(tx); sd.messageIdIndex.clear(tx);
sd.locationIndex.clear(tx); sd.locationIndex.clear(tx);
sd.orderIndex.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);
}
} }
} }
} }