|
Lines 42-47
Link Here
|
| 42 |
private Channel channel; |
42 |
private Channel channel; |
| 43 |
private RpcCallback callback; |
43 |
private RpcCallback callback; |
| 44 |
private byte[] rpcId; |
44 |
private byte[] rpcId; |
|
|
45 |
private int replyMessageOptions = 0; |
| 45 |
|
46 |
|
| 46 |
private HashMap responseMap = new HashMap(); |
47 |
private HashMap responseMap = new HashMap(); |
| 47 |
|
48 |
|
|
Lines 125-131
Link Here
|
| 125 |
rmsg.reply = true; |
126 |
rmsg.reply = true; |
| 126 |
rmsg.message = reply; |
127 |
rmsg.message = reply; |
| 127 |
try { |
128 |
try { |
| 128 |
channel.send(new Member[] {sender}, rmsg,0); |
129 |
channel.send(new Member[] {sender}, rmsg, replyMessageOptions); |
| 129 |
}catch ( Exception x ) { |
130 |
}catch ( Exception x ) { |
| 130 |
log.error("Unable to send back reply in RpcChannel.",x); |
131 |
log.error("Unable to send back reply in RpcChannel.",x); |
| 131 |
} |
132 |
} |
|
Lines 136-142
Link Here
|
| 136 |
channel.removeChannelListener(this); |
137 |
channel.removeChannelListener(this); |
| 137 |
} |
138 |
} |
| 138 |
|
139 |
|
| 139 |
public void finalize() { |
140 |
|
|
|
141 |
public int getReplyMessageOptions() { |
| 142 |
return replyMessageOptions; |
| 143 |
} |
| 144 |
|
| 145 |
|
| 146 |
public void setReplyMessageOptions(int replyMessageOptions) { |
| 147 |
this.replyMessageOptions = replyMessageOptions & ~Channel.SEND_OPTIONS_SYNCHRONIZED_ACK; |
| 148 |
} |
| 149 |
|
| 150 |
|
| 151 |
public void finalize() { |
| 140 |
breakdown(); |
152 |
breakdown(); |
| 141 |
} |
153 |
} |
| 142 |
|
154 |
|