diff options
author | antelder <antelder@13f79535-47bb-0310-9956-ffa450edef68> | 2009-10-13 13:36:57 +0000 |
---|---|---|
committer | antelder <antelder@13f79535-47bb-0310-9956-ffa450edef68> | 2009-10-13 13:36:57 +0000 |
commit | a3e7e822c46912424cc5b96cd18fc15cefdc23eb (patch) | |
tree | 8b712594ae1960b266187f2663c62269439d752b /java/sca | |
parent | f9b2d020ee58b5cc8ca199d94583e10952f7d1ff (diff) |
Move adding the static route code to before the channel start to see if that helps with comms to remote nodes
git-svn-id: http://svn.us.apache.org/repos/asf/tuscany@824753 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'java/sca')
-rw-r--r-- | java/sca/modules/endpoint-tribes/src/main/java/org/apache/tuscany/sca/endpoint/tribes/ReplicatedEndpointRegistry.java | 12 |
1 files changed, 6 insertions, 6 deletions
diff --git a/java/sca/modules/endpoint-tribes/src/main/java/org/apache/tuscany/sca/endpoint/tribes/ReplicatedEndpointRegistry.java b/java/sca/modules/endpoint-tribes/src/main/java/org/apache/tuscany/sca/endpoint/tribes/ReplicatedEndpointRegistry.java index a2823bb88c..7ac9528132 100644 --- a/java/sca/modules/endpoint-tribes/src/main/java/org/apache/tuscany/sca/endpoint/tribes/ReplicatedEndpointRegistry.java +++ b/java/sca/modules/endpoint-tribes/src/main/java/org/apache/tuscany/sca/endpoint/tribes/ReplicatedEndpointRegistry.java @@ -176,12 +176,7 @@ public class ReplicatedEndpointRegistry implements EndpointRegistry, LifeCycleLi new ReplicatedMap(null, createChannel(address, port, bind), timeout, this.domainURI, new ClassLoader[] {ReplicatedEndpointRegistry.class.getClassLoader()}); map.addListener(this); - try { - map.getChannel().start(Channel.DEFAULT); - } catch (ChannelException e) { - throw new IllegalStateException(e); - } - + if (staticRoutes != null) { StaticMembershipInterceptor smi = new StaticMembershipInterceptor(); for (URL staticRoute : staticRoutes) { @@ -198,6 +193,11 @@ public class ReplicatedEndpointRegistry implements EndpointRegistry, LifeCycleLi map.getChannel().addInterceptor(smi); } + try { + map.getChannel().start(Channel.DEFAULT); + } catch (ChannelException e) { + throw new IllegalStateException(e); + } } |