svn commit: r466047 - /incubator/servicemix/trunk/servicemix-common/src/main/java/org/apache/servicemix/common/DefaultComponent.java

[jstrachan]

Author: jstrachan
Date: Fri Oct 20 02:55:39 2006
New Revision: 466047

URL: http://svn.apache.org/viewvc?view=rev&rev=466047
Log:
added a little helper method to make it easier to add endpoints dynamically

Modified:
    
incubator/servicemix/trunk/servicemix-common/src/main/java/org/apache/servicemix/common/DefaultComponent.java

Modified: 
incubator/servicemix/trunk/servicemix-common/src/main/java/org/apache/servicemix/common/DefaultComponent.java
URL: 
http://svn.apache.org/viewvc/incubator/servicemix/trunk/servicemix-common/src/main/java/org/apache/servicemix/common/DefaultComponent.java?view=diff&rev=466047&r1=466046&r2=466047
==============================================================================
--- 
incubator/servicemix/trunk/servicemix-common/src/main/java/org/apache/servicemix/common/DefaultComponent.java
 (original)
+++ 
incubator/servicemix/trunk/servicemix-common/src/main/java/org/apache/servicemix/common/DefaultComponent.java
 Fri Oct 20 02:55:39 2006
@@ -231,7 +231,6 @@
         super.doInit();
         List endpoints = getConfiguredEndpoints();
         if (endpoints != null && !endpoints.isEmpty()) {
-            ServiceUnit su = getServiceUnit();
             Iterator iter = endpoints.iterator();
             while (iter.hasNext()) {
                 Endpoint endpoint = (Endpoint) iter.next();
@@ -239,13 +238,21 @@
                     logger.warn("Ignoring null endpoint in list: " + 
endpoints);
                     continue;
                 }
-                endpoint.setServiceUnit(su);
-                validateEndpoint(endpoint);
-                endpoint.validate();
-                su.addEndpoint(endpoint);
+                addEndpoint(endpoint);
             }
-            getRegistry().registerServiceUnit(su);
+            getRegistry().registerServiceUnit(getServiceUnit());
         }
+    }
+
+    /**
+     * Dynamically adds a new endpoint
+     */
+    protected void addEndpoint(Endpoint endpoint) throws DeploymentException {
+        ServiceUnit su = getServiceUnit();
+        endpoint.setServiceUnit(su);
+        validateEndpoint(endpoint);
+        endpoint.validate();
+        su.addEndpoint(endpoint);
     }