activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From chir...@apache.org
Subject svn commit: r405806 - /incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/ft/MasterBroker.java
Date Fri, 12 May 2006 17:52:06 GMT
Author: chirino
Date: Fri May 12 10:52:04 2006
New Revision: 405806

URL: http://svn.apache.org/viewcvs?rev=405806&view=rev
Log:
Honnor the QoS requested by the client when replicating to the slave broker.

Modified:
    incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/ft/MasterBroker.java

Modified: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/ft/MasterBroker.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/ft/MasterBroker.java?rev=405806&r1=405805&r2=405806&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/ft/MasterBroker.java
(original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/ft/MasterBroker.java
Fri May 12 10:52:04 2006
@@ -328,7 +328,7 @@
 
     protected void sendToSlave(Message message){
         
-        if (message.isPersistent() && !message.isInTransaction()){
+        if ( message.isResponseRequired() ){
             sendSyncToSlave(message);
         }else{
             sendAsyncToSlave(message);
@@ -338,8 +338,7 @@
     }
     
     protected void sendToSlave(MessageAck ack){
-       
-        if (ack.isInTransaction()){
+        if ( ack.isResponseRequired() ){
             sendAsyncToSlave(ack);
         }else{
             sendSyncToSlave(ack);



Mime
View raw message