summaryrefslogtreecommitdiffstats
path: root/sca-java-2.x/trunk/modules/endpoint-tribes/src/main
diff options
context:
space:
mode:
authormcombellack <mcombellack@13f79535-47bb-0310-9956-ffa450edef68>2010-01-17 21:30:23 +0000
committermcombellack <mcombellack@13f79535-47bb-0310-9956-ffa450edef68>2010-01-17 21:30:23 +0000
commite73da0c63682e2a8210d6ea7cc6017be04019ae3 (patch)
tree770899ee708eb956b2265878e98f350450eef3a2 /sca-java-2.x/trunk/modules/endpoint-tribes/src/main
parent62214f87055adcc87e85177d351157658c3682bf (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.java4
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());