You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@servicemix.apache.org by js...@apache.org on 2006/10/20 11:55:42 UTC
svn commit: r466047 -
/incubator/servicemix/trunk/servicemix-common/src/main/java/org/apache/servicemix/common/DefaultComponent.java
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);
}