You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@servicemix.apache.org by gn...@apache.org on 2006/10/15 21:10:27 UTC

svn commit: r464251 - in /incubator/servicemix/trunk/servicemix-eip: ./ src/main/java/org/apache/servicemix/eip/ src/test/java/org/apache/servicemix/eip/

Author: gnodet
Date: Sun Oct 15 12:10:26 2006
New Revision: 464251

URL: http://svn.apache.org/viewvc?view=rev&rev=464251
Log:
Convert EIP component to new DefaultComponent

Removed:
    incubator/servicemix/trunk/servicemix-eip/src/main/java/org/apache/servicemix/eip/EIPDeployer.java
    incubator/servicemix/trunk/servicemix-eip/src/main/java/org/apache/servicemix/eip/EIPLifeCycle.java
    incubator/servicemix/trunk/servicemix-eip/src/main/java/org/apache/servicemix/eip/EIPSpringComponent.java
Modified:
    incubator/servicemix/trunk/servicemix-eip/   (props changed)
    incubator/servicemix/trunk/servicemix-eip/src/main/java/org/apache/servicemix/eip/EIPComponent.java
    incubator/servicemix/trunk/servicemix-eip/src/test/java/org/apache/servicemix/eip/AbstractEIPTest.java

Propchange: incubator/servicemix/trunk/servicemix-eip/
------------------------------------------------------------------------------
--- svn:ignore (original)
+++ svn:ignore Sun Oct 15 12:10:26 2006
@@ -2,3 +2,5 @@
 .classpath
 .project
 cobertura.ser
+derby.log
+ServiceMixFlow.dot

Modified: incubator/servicemix/trunk/servicemix-eip/src/main/java/org/apache/servicemix/eip/EIPComponent.java
URL: http://svn.apache.org/viewvc/incubator/servicemix/trunk/servicemix-eip/src/main/java/org/apache/servicemix/eip/EIPComponent.java?view=diff&rev=464251&r1=464250&r2=464251
==============================================================================
--- incubator/servicemix/trunk/servicemix-eip/src/main/java/org/apache/servicemix/eip/EIPComponent.java (original)
+++ incubator/servicemix/trunk/servicemix-eip/src/main/java/org/apache/servicemix/eip/EIPComponent.java Sun Oct 15 12:10:26 2006
@@ -16,30 +16,72 @@
  */
 package org.apache.servicemix.eip;
 
-import org.apache.servicemix.common.BaseComponent;
-import org.apache.servicemix.common.BaseLifeCycle;
-import org.apache.servicemix.common.BaseServiceUnitManager;
-import org.apache.servicemix.common.Deployer;
+import java.util.List;
+
+import org.apache.servicemix.common.DefaultComponent;
 
 /**
  * @author gnodet
  * @version $Revision: 376451 $
+ * @org.apache.xbean.XBean element="component"
+ *                  description="An EIP component"
  */
-public class EIPComponent extends BaseComponent {
+public class EIPComponent extends DefaultComponent {
 
-    /* (non-Javadoc)
-     * @see org.servicemix.common.BaseComponent#createLifeCycle()
+    private EIPEndpoint[] endpoints;
+    private EIPConfiguration configuration;
+
+    public EIPComponent() {
+        configuration = new EIPConfiguration();
+    }
+    
+    /**
+     * @return the configuration
+     */
+    protected EIPConfiguration getConfiguration() {
+        return configuration;
+    }
+
+    /**
+     * @param configuration the configuration to set
+     */
+    protected void setConfiguration(EIPConfiguration configuration) {
+        this.configuration = configuration;
+    }
+
+    /**
+     * @return Returns the endpoints.
      */
-    protected BaseLifeCycle createLifeCycle() {
-        return new EIPLifeCycle(this);
+    public EIPEndpoint[] getEndpoints() {
+        return endpoints;
     }
 
+    /**
+     * @param endpoints The endpoints to set.
+     */
+    public void setEndpoints(EIPEndpoint[] endpoints) {
+        this.endpoints = endpoints;
+    }
+    
     /* (non-Javadoc)
-     * @see org.servicemix.common.BaseComponent#createServiceUnitManager()
+     * @see org.servicemix.common.BaseComponentLifeCycle#getExtensionMBean()
      */
-    public BaseServiceUnitManager createServiceUnitManager() {
-        Deployer[] deployers = new Deployer[] { new EIPDeployer(this) };
-        return new BaseServiceUnitManager(this, deployers);
+    protected Object getExtensionMBean() throws Exception {
+        return configuration;
+    }
+
+    protected void doInit() throws Exception {
+        super.doInit();
+        configuration.setRootDir(context.getWorkspaceRoot());
+        configuration.load();
+    }
+
+    protected List getConfiguredEndpoints() {
+        return asList(endpoints);
+    }
+
+    protected Class[] getEndpointClasses() {
+        return new Class[] { EIPEndpoint.class };
     }
 
 }

Modified: incubator/servicemix/trunk/servicemix-eip/src/test/java/org/apache/servicemix/eip/AbstractEIPTest.java
URL: http://svn.apache.org/viewvc/incubator/servicemix/trunk/servicemix-eip/src/test/java/org/apache/servicemix/eip/AbstractEIPTest.java?view=diff&rev=464251&r1=464250&r2=464251
==============================================================================
--- incubator/servicemix/trunk/servicemix-eip/src/test/java/org/apache/servicemix/eip/AbstractEIPTest.java (original)
+++ incubator/servicemix/trunk/servicemix-eip/src/test/java/org/apache/servicemix/eip/AbstractEIPTest.java Sun Oct 15 12:10:26 2006
@@ -98,7 +98,7 @@
     }
     
     protected void activateComponent(EIPEndpoint endpoint, String name) throws Exception {
-        EIPSpringComponent eip = new EIPSpringComponent();
+        EIPComponent eip = new EIPComponent();
         endpoint.setService(new QName(name));
         endpoint.setEndpoint("ep");
         eip.setEndpoints(new EIPEndpoint[] { endpoint });