activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From tab...@apache.org
Subject svn commit: r1311780 - /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/kahadb/MessageDatabase.java
Date Tue, 10 Apr 2012 15:12:57 GMT
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);
-                }
-
             }
         }
     }



Mime
View raw message