Apache
/
activemq
mirror of https://github.com/apache/activemq.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Honnor the QoS requested by the client when replicating to the slave broker. 

git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@405806 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Hiram R. Chirino 2006-05-12 17:52:04 +00:00
parent 3b973bce32
commit 7947655e5f
1 changed files with 2 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
activemq-core/src/main/java/org/apache/activemq/broker/ft/MasterBroker.java
View File

@ -328,7 +328,7 @@ public class MasterBroker extends InsertableMutableBrokerFilter{
protected void sendToSlave(Message message){
if (message.isPersistent() && !message.isInTransaction()){
if ( message.isResponseRequired() ){
sendSyncToSlave(message);
}else{
sendAsyncToSlave(message);
@ -338,8 +338,7 @@ public class MasterBroker extends InsertableMutableBrokerFilter{
}
protected void sendToSlave(MessageAck ack){
if (ack.isInTransaction()){
if ( ack.isResponseRequired() ){
sendAsyncToSlave(ack);
}else{
sendSyncToSlave(ack);