Author: mcombellack
Date: Sun Jan 17 21:30:23 2010
New Revision: 900220
URL: http://svn.apache.org/viewvc?rev=900220&view=rev
Log:
Updated code so that it access static constants on RpcChannel in a static
manner rather than on an instance of RpcChannel
Modified:
tuscany/sca-java-2.x/trunk/modules/endpoint-tribes/src/main/java/org/apache/tuscany/sca/endpoint/tribes/AbstractReplicatedMap.java
Modified:
tuscany/sca-java-2.x/trunk/modules/endpoint-tribes/src/main/java/org/apache/tuscany/sca/endpoint/tribes/AbstractReplicatedMap.java
URL:
http://svn.apache.org/viewvc/tuscany/sca-java-2.x/trunk/modules/endpoint-tribes/src/main/java/org/apache/tuscany/sca/endpoint/tribes/AbstractReplicatedMap.java?rev=900220&r1=900219&r2=900220&view=diff
==============================================================================
---
tuscany/sca-java-2.x/trunk/modules/endpoint-tribes/src/main/java/org/apache/tuscany/sca/endpoint/tribes/AbstractReplicatedMap.java
(original)
+++
tuscany/sca-java-2.x/trunk/modules/endpoint-tribes/src/main/java/org/apache/tuscany/sca/endpoint/tribes/AbstractReplicatedMap.java
Sun Jan 17 21:30:23 2010
@@ -263,7 +263,7 @@
Response[] resp =
rpcChannel.send(channel.getMembers(),
msg,
- rpcChannel.ALL_REPLY,
+ RpcChannel.ALL_REPLY,
(channelSendOptions),
(int)accessTimeout);
for (int i = 0; i < resp.length; i++) {
@@ -310,7 +310,7 @@
new MapMessage(this.mapContextName, msgtype, false, null, null,
null, channel.getLocalMember(false), null);
if (rpc) {
Response[] resp =
- rpcChannel.send(channel.getMembers(), msg,
rpcChannel.FIRST_REPLY, (channelSendOptions), rpcTimeout);
+ rpcChannel.send(channel.getMembers(), msg,
RpcChannel.FIRST_REPLY, (channelSendOptions), rpcTimeout);
for (int i = 0; i < resp.length; i++) {
mapMemberAdded(resp[i].getSource());
messageReceived(resp[i].getMessage(), resp[i].getSource());