activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From rajdav...@apache.org
Subject svn commit: r509720 - /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/ResponseCorrelator.java
Date Tue, 20 Feb 2007 19:40:21 GMT
Author: rajdavies
Date: Tue Feb 20 11:40:20 2007
New Revision: 509720

URL: http://svn.apache.org/viewvc?view=rev&rev=509720
Log:
small op

Modified:
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/ResponseCorrelator.java

Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/ResponseCorrelator.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/ResponseCorrelator.java?view=diff&rev=509720&r1=509719&r2=509720
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/ResponseCorrelator.java
(original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/ResponseCorrelator.java
Tue Feb 20 11:40:20 2007
@@ -43,7 +43,7 @@
     
     private final ConcurrentHashMap requestMap = new ConcurrentHashMap();
     private IntSequenceGenerator sequenceGenerator;
-    
+    private final boolean debug = log.isDebugEnabled();
     public ResponseCorrelator(Transport next) {
         this(next, new IntSequenceGenerator());
     }
@@ -82,7 +82,7 @@
     
     public void onCommand(Object o) {
     	Command command = (Command) o;
-        boolean debug = log.isDebugEnabled();
+        
         if( command.isResponse() ) {
             Response response = (Response) command;
             FutureResponse future = (FutureResponse) requestMap.remove(new Integer(response.getCorrelationId()));



Mime
View raw message