activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From chir...@apache.org
Subject svn commit: r511093 - in /activemq/branches/activemq-4.1: ./ activemq-core/src/main/java/org/apache/activemq/broker/TransportConnection.java
Date Fri, 23 Feb 2007 20:26:17 GMT
Author: chirino
Date: Fri Feb 23 12:26:16 2007
New Revision: 511093

URL: http://svn.apache.org/viewvc?view=rev&rev=511093
Log:
 r249@34:  chirino | 2007-02-23 14:50:22 -0500
 Don't send a response back if the broker requested that we don't send it.
 

Modified:
    activemq/branches/activemq-4.1/   (props changed)
    activemq/branches/activemq-4.1/activemq-core/src/main/java/org/apache/activemq/broker/TransportConnection.java

Propchange: activemq/branches/activemq-4.1/
------------------------------------------------------------------------------
--- svk:merge (original)
+++ svk:merge Fri Feb 23 12:26:16 2007
@@ -1 +1 @@
-635f1f41-eb29-0410-ac9d-be9e2c357fdd:/local/amq-4.1-port:248
+635f1f41-eb29-0410-ac9d-be9e2c357fdd:/local/amq-4.1-port:249

Modified: activemq/branches/activemq-4.1/activemq-core/src/main/java/org/apache/activemq/broker/TransportConnection.java
URL: http://svn.apache.org/viewvc/activemq/branches/activemq-4.1/activemq-core/src/main/java/org/apache/activemq/broker/TransportConnection.java?view=diff&rev=511093&r1=511092&r2=511093
==============================================================================
--- activemq/branches/activemq-4.1/activemq-core/src/main/java/org/apache/activemq/broker/TransportConnection.java
(original)
+++ activemq/branches/activemq-4.1/activemq-core/src/main/java/org/apache/activemq/broker/TransportConnection.java
Fri Feb 23 12:26:16 2007
@@ -301,10 +301,6 @@
             }
         }        
         if( responseRequired ) {
-            if( response == null ) {
-                response = new Response();                
-            }
-            response.setCorrelationId(commandId);
             if( context!=null && context.isDontSendReponse() ) {
                 // No need to send back a response at this time.
             } else {



Mime
View raw message