You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@servicemix.apache.org by ge...@apache.org on 2008/09/22 16:27:07 UTC
svn commit: r697848 - in
/servicemix/smx3/trunk/deployables/serviceengines/servicemix-lwcontainer/src/main/java/org/apache/servicemix/lwcontainer:
LwContainerComponent.java LwContainerEndpoint.java LwContainerExtra.java
Author: gertv
Date: Mon Sep 22 07:27:06 2008
New Revision: 697848
URL: http://svn.apache.org/viewvc?rev=697848&view=rev
Log:
SM-1576: servicemix-lwcontainer now builds again after changes to Endpoint classes
Modified:
servicemix/smx3/trunk/deployables/serviceengines/servicemix-lwcontainer/src/main/java/org/apache/servicemix/lwcontainer/LwContainerComponent.java
servicemix/smx3/trunk/deployables/serviceengines/servicemix-lwcontainer/src/main/java/org/apache/servicemix/lwcontainer/LwContainerEndpoint.java
servicemix/smx3/trunk/deployables/serviceengines/servicemix-lwcontainer/src/main/java/org/apache/servicemix/lwcontainer/LwContainerExtra.java
Modified: servicemix/smx3/trunk/deployables/serviceengines/servicemix-lwcontainer/src/main/java/org/apache/servicemix/lwcontainer/LwContainerComponent.java
URL: http://svn.apache.org/viewvc/servicemix/smx3/trunk/deployables/serviceengines/servicemix-lwcontainer/src/main/java/org/apache/servicemix/lwcontainer/LwContainerComponent.java?rev=697848&r1=697847&r2=697848&view=diff
==============================================================================
--- servicemix/smx3/trunk/deployables/serviceengines/servicemix-lwcontainer/src/main/java/org/apache/servicemix/lwcontainer/LwContainerComponent.java (original)
+++ servicemix/smx3/trunk/deployables/serviceengines/servicemix-lwcontainer/src/main/java/org/apache/servicemix/lwcontainer/LwContainerComponent.java Mon Sep 22 07:27:06 2008
@@ -16,9 +16,12 @@
*/
package org.apache.servicemix.lwcontainer;
+import javax.jbi.messaging.MessageExchange;
+
import org.apache.servicemix.common.BaseComponent;
import org.apache.servicemix.common.BaseServiceUnitManager;
import org.apache.servicemix.common.Deployer;
+import org.apache.servicemix.common.Endpoint;
public class LwContainerComponent extends BaseComponent {
@@ -29,5 +32,13 @@
Deployer[] deployers = new Deployer[] {new LwContainerXBeanDeployer(this) };
return new BaseServiceUnitManager(this, deployers);
}
+
+ public void prepareShutdown(Endpoint endpoint) throws InterruptedException {
+ lifeCycle.prepareShutdown(endpoint);
+ }
+
+ public void handleExchange(Endpoint endpoint, MessageExchange exchange, boolean add) {
+ lifeCycle.handleExchange(endpoint, exchange, add);
+ }
}
Modified: servicemix/smx3/trunk/deployables/serviceengines/servicemix-lwcontainer/src/main/java/org/apache/servicemix/lwcontainer/LwContainerEndpoint.java
URL: http://svn.apache.org/viewvc/servicemix/smx3/trunk/deployables/serviceengines/servicemix-lwcontainer/src/main/java/org/apache/servicemix/lwcontainer/LwContainerEndpoint.java?rev=697848&r1=697847&r2=697848&view=diff
==============================================================================
--- servicemix/smx3/trunk/deployables/serviceengines/servicemix-lwcontainer/src/main/java/org/apache/servicemix/lwcontainer/LwContainerEndpoint.java (original)
+++ servicemix/smx3/trunk/deployables/serviceengines/servicemix-lwcontainer/src/main/java/org/apache/servicemix/lwcontainer/LwContainerEndpoint.java Mon Sep 22 07:27:06 2008
@@ -17,17 +17,18 @@
package org.apache.servicemix.lwcontainer;
import javax.jbi.component.ComponentContext;
+import javax.jbi.messaging.MessageExchange;
import javax.jbi.messaging.MessageExchange.Role;
import javax.xml.namespace.QName;
import org.apache.activemq.util.IdGenerator;
-import org.apache.servicemix.common.Endpoint;
import org.apache.servicemix.common.ExchangeProcessor;
+import org.apache.servicemix.common.endpoints.AbstractEndpoint;
import org.apache.servicemix.jbi.container.ActivationSpec;
import org.apache.servicemix.jbi.container.JBIContainer;
import org.apache.servicemix.jbi.framework.ComponentContextImpl;
-public class LwContainerEndpoint extends Endpoint {
+public class LwContainerEndpoint extends AbstractEndpoint {
private static final QName SERVICE_NAME = new QName("http://lwcontainer.servicemix.org", "LwContainerComponent");
@@ -60,7 +61,7 @@
public ExchangeProcessor getProcessor() {
throw new UnsupportedOperationException();
}
-
+
public JBIContainer getContainer() {
ComponentContext context = getServiceUnit().getComponent().getComponentContext();
if (context instanceof ComponentContextImpl) {
@@ -69,4 +70,20 @@
throw new IllegalStateException("LwContainer component can only be deployed in ServiceMix");
}
+ @Override
+ public void process(MessageExchange exchange) throws Exception {
+ getProcessor().process(exchange);
+ }
+
+ @Override
+ public void start() throws Exception {
+ // gracefully do nothing
+ }
+
+ @Override
+ public void stop() throws Exception {
+ // gracefully do nothing
+
+ }
+
}
Modified: servicemix/smx3/trunk/deployables/serviceengines/servicemix-lwcontainer/src/main/java/org/apache/servicemix/lwcontainer/LwContainerExtra.java
URL: http://svn.apache.org/viewvc/servicemix/smx3/trunk/deployables/serviceengines/servicemix-lwcontainer/src/main/java/org/apache/servicemix/lwcontainer/LwContainerExtra.java?rev=697848&r1=697847&r2=697848&view=diff
==============================================================================
--- servicemix/smx3/trunk/deployables/serviceengines/servicemix-lwcontainer/src/main/java/org/apache/servicemix/lwcontainer/LwContainerExtra.java (original)
+++ servicemix/smx3/trunk/deployables/serviceengines/servicemix-lwcontainer/src/main/java/org/apache/servicemix/lwcontainer/LwContainerExtra.java Mon Sep 22 07:27:06 2008
@@ -34,6 +34,7 @@
import org.apache.servicemix.common.DefaultComponent;
import org.apache.servicemix.common.Endpoint;
import org.apache.servicemix.common.ExchangeProcessor;
+import org.apache.servicemix.common.endpoints.AbstractEndpoint;
import org.apache.servicemix.id.IdGenerator;
import org.apache.servicemix.jbi.container.JBIContainer;
import org.apache.servicemix.jbi.framework.ComponentContextImpl;
@@ -46,7 +47,7 @@
/**
* Fake endpoint that hold components, endpoints, listeners and services.
*/
-public class LwContainerExtra extends Endpoint {
+public class LwContainerExtra extends AbstractEndpoint {
private Map components;
private Map endpoints;
@@ -237,4 +238,19 @@
return idGenerator.generateId();
}
+ @Override
+ public void process(MessageExchange exchange) throws Exception {
+ getProcessor().process(exchange);
+ }
+
+ @Override
+ public void start() throws Exception {
+ // gracefully do nothing
+ }
+
+ @Override
+ public void stop() throws Exception {
+ // gracefully do nothing
+ }
+
}