svn commit: r808869 - /tuscany/java/sca/modules/endpoint-tribes/src/main/java/org/apache/tuscany/sca/endpoint/tribes/ReplicatedEndpointRegistry.java

[an...@apache.org]

Author: antelder
Date: Fri Aug 28 12:58:09 2009
New Revision: 808869

URL: http://svn.apache.org/viewvc?rev=808869&view=rev
Log:
Update the tribes based endpoint registry to support being configured from the runtime configuration

Modified:
    tuscany/java/sca/modules/endpoint-tribes/src/main/java/org/apache/tuscany/sca/endpoint/tribes/ReplicatedEndpointRegistry.java

Modified: tuscany/java/sca/modules/endpoint-tribes/src/main/java/org/apache/tuscany/sca/endpoint/tribes/ReplicatedEndpointRegistry.java
URL: http://svn.apache.org/viewvc/tuscany/java/sca/modules/endpoint-tribes/src/main/java/org/apache/tuscany/sca/endpoint/tribes/ReplicatedEndpointRegistry.java?rev=808869&r1=808868&r2=808869&view=diff
==============================================================================
--- tuscany/java/sca/modules/endpoint-tribes/src/main/java/org/apache/tuscany/sca/endpoint/tribes/ReplicatedEndpointRegistry.java (original)
+++ tuscany/java/sca/modules/endpoint-tribes/src/main/java/org/apache/tuscany/sca/endpoint/tribes/ReplicatedEndpointRegistry.java Fri Aug 28 12:58:09 2009
@@ -38,8 +38,10 @@
 import org.apache.tuscany.sca.assembly.EndpointReference;
 import org.apache.tuscany.sca.core.ExtensionPointRegistry;
 import org.apache.tuscany.sca.core.LifeCycleListener;
+import org.apache.tuscany.sca.core.UtilityExtensionPoint;
 import org.apache.tuscany.sca.endpoint.tribes.AbstractReplicatedMap.MapEntry;
 import org.apache.tuscany.sca.endpoint.tribes.MapStore.MapListener;
+import org.apache.tuscany.sca.management.ConfigAttributes;
 import org.apache.tuscany.sca.runtime.EndpointListener;
 import org.apache.tuscany.sca.runtime.EndpointRegistry;
 
@@ -87,6 +89,17 @@
 
     public ReplicatedEndpointRegistry(ExtensionPointRegistry registry, Map<String, String> attributes) {
         this.registry = registry;
+
+        UtilityExtensionPoint utilities = registry.getExtensionPoint(UtilityExtensionPoint.class);
+        ConfigAttributes domainConfig = utilities.getUtility(ConfigAttributes.class);
+        if (domainConfig != null) {
+            setConfig(domainConfig.getAttributes());
+        } else {
+            setConfig(attributes);
+        }
+    }
+
+    private void setConfig(Map<String, String> attributes) {
         String portStr = attributes.get("port");
         if (portStr != null) {
             port = Integer.parseInt(portStr);
@@ -100,7 +113,6 @@
         if (timeoutStr != null) {
             timeout = Integer.parseInt(timeoutStr);
         }
-        // start();
     }
 
     public ReplicatedEndpointRegistry(String domainURI) {