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 2008/09/16 14:48:41 UTC
svn commit: r695851 - in
/servicemix/components/engines/servicemix-jsr181/trunk/src/test/java:
org/apache/servicemix/jsr181/ test/
Author: gnodet
Date: Tue Sep 16 05:48:40 2008
New Revision: 695851
URL: http://svn.apache.org/viewvc?rev=695851&view=rev
Log:
SM-1576: Change endpoints lifecycle to use activate / start / stop / deactivate
Modified:
servicemix/components/engines/servicemix-jsr181/trunk/src/test/java/org/apache/servicemix/jsr181/Jsr181ComplexPojoTest.java
servicemix/components/engines/servicemix-jsr181/trunk/src/test/java/org/apache/servicemix/jsr181/Jsr181ComponentTest.java
servicemix/components/engines/servicemix-jsr181/trunk/src/test/java/org/apache/servicemix/jsr181/Jsr181SpringProxyTest.java
servicemix/components/engines/servicemix-jsr181/trunk/src/test/java/test/TestEndpoint.java
Modified: servicemix/components/engines/servicemix-jsr181/trunk/src/test/java/org/apache/servicemix/jsr181/Jsr181ComplexPojoTest.java
URL: http://svn.apache.org/viewvc/servicemix/components/engines/servicemix-jsr181/trunk/src/test/java/org/apache/servicemix/jsr181/Jsr181ComplexPojoTest.java?rev=695851&r1=695850&r2=695851&view=diff
==============================================================================
--- servicemix/components/engines/servicemix-jsr181/trunk/src/test/java/org/apache/servicemix/jsr181/Jsr181ComplexPojoTest.java (original)
+++ servicemix/components/engines/servicemix-jsr181/trunk/src/test/java/org/apache/servicemix/jsr181/Jsr181ComplexPojoTest.java Tue Sep 16 05:48:40 2008
@@ -120,6 +120,8 @@
me.getInMessage().setContent(new StringSource(
"<oneWay xmlns='http://jsr181.servicemix.apache.org'><in0>world</in0></oneWay>"));
client.sendSync(me);
+ log.info(new SourceTransformer().contentToString(me.getOutMessage()));
+ client.done(me);
// Wait all acks being processed
Thread.sleep(100);
@@ -146,7 +148,7 @@
InOut me = client.createInOutExchange();
me.setInterfaceName(new QName("http://jsr181.servicemix.apache.org", "ComplexPojoPortType"));
me.getInMessage().setContent(new StringSource(
- "<twoWay xmlns='http://jsr181.servicemix.apache.org'><in0>world ã</in0></twoWay>"));
+ "<twoWay xmlns='http://jsr181.servicemix.apache.org'><in0>world �</in0></twoWay>"));
client.sendSync(me);
log.info(new SourceTransformer().contentToString(me.getOutMessage()));
client.done(me);
Modified: servicemix/components/engines/servicemix-jsr181/trunk/src/test/java/org/apache/servicemix/jsr181/Jsr181ComponentTest.java
URL: http://svn.apache.org/viewvc/servicemix/components/engines/servicemix-jsr181/trunk/src/test/java/org/apache/servicemix/jsr181/Jsr181ComponentTest.java?rev=695851&r1=695850&r2=695851&view=diff
==============================================================================
--- servicemix/components/engines/servicemix-jsr181/trunk/src/test/java/org/apache/servicemix/jsr181/Jsr181ComponentTest.java (original)
+++ servicemix/components/engines/servicemix-jsr181/trunk/src/test/java/org/apache/servicemix/jsr181/Jsr181ComponentTest.java Tue Sep 16 05:48:40 2008
@@ -130,9 +130,11 @@
Jsr181Component component = new Jsr181Component();
container.activateComponent(component, "JSR181Component");
component.getServiceUnitManager().deploy("d/u", getServiceUnitPath("good1"));
+ component.getServiceUnitManager().init("d/u", getServiceUnitPath("good1"));
component.getServiceUnitManager().shutDown("d/u");
component.getServiceUnitManager().undeploy("d/u", getServiceUnitPath("good1"));
component.getServiceUnitManager().deploy("d/u", getServiceUnitPath("good1"));
+ component.getServiceUnitManager().init("d/u", getServiceUnitPath("good1"));
component.getServiceUnitManager().start("d/u");
component.getServiceUnitManager().stop("d/u");
component.getServiceUnitManager().shutDown("d/u");
Modified: servicemix/components/engines/servicemix-jsr181/trunk/src/test/java/org/apache/servicemix/jsr181/Jsr181SpringProxyTest.java
URL: http://svn.apache.org/viewvc/servicemix/components/engines/servicemix-jsr181/trunk/src/test/java/org/apache/servicemix/jsr181/Jsr181SpringProxyTest.java?rev=695851&r1=695850&r2=695851&view=diff
==============================================================================
--- servicemix/components/engines/servicemix-jsr181/trunk/src/test/java/org/apache/servicemix/jsr181/Jsr181SpringProxyTest.java (original)
+++ servicemix/components/engines/servicemix-jsr181/trunk/src/test/java/org/apache/servicemix/jsr181/Jsr181SpringProxyTest.java Tue Sep 16 05:48:40 2008
@@ -41,7 +41,9 @@
client.sendSync(me);
if (me.getStatus() == ExchangeStatus.ERROR) {
if (me.getFault() != null) {
- fail("Received fault: " + new SourceTransformer().toString(me.getFault().getContent()));
+ String txt = new SourceTransformer().toString(me.getFault().getContent());
+ client.done(me);
+ fail("Received fault: " + txt);
} else if (me.getError() != null) {
throw me.getError();
} else {
@@ -49,6 +51,7 @@
}
} else {
logger.info(new SourceTransformer().toString(me.getOutMessage().getContent()));
+ client.done(me);
}
}
Modified: servicemix/components/engines/servicemix-jsr181/trunk/src/test/java/test/TestEndpoint.java
URL: http://svn.apache.org/viewvc/servicemix/components/engines/servicemix-jsr181/trunk/src/test/java/test/TestEndpoint.java?rev=695851&r1=695850&r2=695851&view=diff
==============================================================================
--- servicemix/components/engines/servicemix-jsr181/trunk/src/test/java/test/TestEndpoint.java (original)
+++ servicemix/components/engines/servicemix-jsr181/trunk/src/test/java/test/TestEndpoint.java Tue Sep 16 05:48:40 2008
@@ -17,11 +17,12 @@
package test;
import javax.jbi.messaging.MessageExchange.Role;
+import javax.jbi.messaging.MessageExchange;
import org.apache.servicemix.common.Endpoint;
-import org.apache.servicemix.common.ExchangeProcessor;
+import org.apache.servicemix.common.endpoints.AbstractEndpoint;
-public class TestEndpoint extends Endpoint {
+public class TestEndpoint extends AbstractEndpoint {
public Role getRole() {
// TODO Auto-generated method stub
@@ -30,17 +31,21 @@
public void activate() throws Exception {
// TODO Auto-generated method stub
-
}
public void deactivate() throws Exception {
// TODO Auto-generated method stub
+ }
+ public void start() throws Exception {
+ // TODO Auto-generated method stub
}
- public ExchangeProcessor getProcessor() {
+ public void stop() throws Exception {
// TODO Auto-generated method stub
- return null;
}
+ public void process(MessageExchange exchange) throws Exception {
+ // TODO Auto-generated method stub
+ }
}