Index: group/RpcChannel.java =================================================================== --- group/RpcChannel.java (revision 792283) +++ group/RpcChannel.java (working copy) @@ -42,6 +42,7 @@ private Channel channel; private RpcCallback callback; private byte[] rpcId; + private int replyMessageOptions = 0; private HashMap responseMap = new HashMap(); @@ -125,7 +126,7 @@ rmsg.reply = true; rmsg.message = reply; try { - channel.send(new Member[] {sender}, rmsg,0); + channel.send(new Member[] {sender}, rmsg, replyMessageOptions); }catch ( Exception x ) { log.error("Unable to send back reply in RpcChannel.",x); } @@ -136,7 +137,18 @@ channel.removeChannelListener(this); } - public void finalize() { + + public int getReplyMessageOptions() { + return replyMessageOptions; + } + + + public void setReplyMessageOptions(int replyMessageOptions) { + this.replyMessageOptions = replyMessageOptions & ~Channel.SEND_OPTIONS_SYNCHRONIZED_ACK; + } + + + public void finalize() { breakdown(); }