svn commit: r583483 - /incubator/qpid/branches/M2.1/java/perftests/src/main/java/org/apache/qpid/requestreply/PingPongProducer.java

[rupertlssmith]

Author: rupertlssmith
Date: Wed Oct 10 07:21:20 2007
New Revision: 583483

URL: http://svn.apache.org/viewvc?rev=583483&view=rev
Log:
Removed debug logging from performance test code.

Modified:
    
incubator/qpid/branches/M2.1/java/perftests/src/main/java/org/apache/qpid/requestreply/PingPongProducer.java

Modified: 
incubator/qpid/branches/M2.1/java/perftests/src/main/java/org/apache/qpid/requestreply/PingPongProducer.java
URL: 
http://svn.apache.org/viewvc/incubator/qpid/branches/M2.1/java/perftests/src/main/java/org/apache/qpid/requestreply/PingPongProducer.java?rev=583483&r1=583482&r2=583483&view=diff
==============================================================================
--- 
incubator/qpid/branches/M2.1/java/perftests/src/main/java/org/apache/qpid/requestreply/PingPongProducer.java
 (original)
+++ 
incubator/qpid/branches/M2.1/java/perftests/src/main/java/org/apache/qpid/requestreply/PingPongProducer.java
 Wed Oct 10 07:21:20 2007
@@ -868,7 +868,7 @@
             long timestamp = getTimestamp(message);
             long pingTime = now - timestamp;
 
-            NDC.push("id" + instanceId + "/cons" + consumerNo);
+            // NDC.push("id" + instanceId + "/cons" + consumerNo);
 
             // Extract the messages correlation id.
             String correlationID = message.getJMSCorrelationID();
@@ -904,7 +904,7 @@
                             / (_isPubSub ? getConsumersPerDestination() : 1);
 
                         // log.debug("unreceived = " + unreceived);
-                        log.debug("unreceivedSize = " + unreceivedSize);
+                        // log.debug("unreceivedSize = " + unreceivedSize);
 
                         synchronized (_sendPauseMonitor)
                         {
@@ -988,7 +988,7 @@
         finally
         {
             // log.debug("public void onMessageWithConsumerNo(Message message, 
int consumerNo): ending");
-            NDC.clear();
+            // NDC.clear();
         }
     }