diff options
author | mcombellack <mcombellack@13f79535-47bb-0310-9956-ffa450edef68> | 2010-01-17 21:30:23 +0000 |
---|---|---|
committer | mcombellack <mcombellack@13f79535-47bb-0310-9956-ffa450edef68> | 2010-01-17 21:30:23 +0000 |
commit | e73da0c63682e2a8210d6ea7cc6017be04019ae3 (patch) | |
tree | 770899ee708eb956b2265878e98f350450eef3a2 /sca-java-2.x/trunk/modules/endpoint-tribes/src/main | |
parent | 62214f87055adcc87e85177d351157658c3682bf (diff) |
Updated code so that it access static constants on RpcChannel in a static manner rather than on an instance of RpcChannel
git-svn-id: http://svn.us.apache.org/repos/asf/tuscany@900220 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'sca-java-2.x/trunk/modules/endpoint-tribes/src/main')
-rw-r--r-- | sca-java-2.x/trunk/modules/endpoint-tribes/src/main/java/org/apache/tuscany/sca/endpoint/tribes/AbstractReplicatedMap.java | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/sca-java-2.x/trunk/modules/endpoint-tribes/src/main/java/org/apache/tuscany/sca/endpoint/tribes/AbstractReplicatedMap.java b/sca-java-2.x/trunk/modules/endpoint-tribes/src/main/java/org/apache/tuscany/sca/endpoint/tribes/AbstractReplicatedMap.java index 98c6739854..47b3450594 100644 --- a/sca-java-2.x/trunk/modules/endpoint-tribes/src/main/java/org/apache/tuscany/sca/endpoint/tribes/AbstractReplicatedMap.java +++ b/sca-java-2.x/trunk/modules/endpoint-tribes/src/main/java/org/apache/tuscany/sca/endpoint/tribes/AbstractReplicatedMap.java @@ -263,7 +263,7 @@ public abstract class AbstractReplicatedMap extends MapStore implements RpcCallb 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 @@ public abstract class AbstractReplicatedMap extends MapStore implements RpcCallb 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()); |