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
+ }
+
}
