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/07/16 01:10:45 UTC
svn commit: r677083 -
/servicemix/components/bindings/servicemix-cxf-bc/trunk/src/test/java/org/apache/servicemix/cxfbc/CxfBcProviderTest.java
Author: gnodet
Date: Tue Jul 15 16:10:45 2008
New Revision: 677083
URL: http://svn.apache.org/viewvc?rev=677083&view=rev
Log:
Fix cxf-bc junit tests
Modified:
servicemix/components/bindings/servicemix-cxf-bc/trunk/src/test/java/org/apache/servicemix/cxfbc/CxfBcProviderTest.java
Modified: servicemix/components/bindings/servicemix-cxf-bc/trunk/src/test/java/org/apache/servicemix/cxfbc/CxfBcProviderTest.java
URL: http://svn.apache.org/viewvc/servicemix/components/bindings/servicemix-cxf-bc/trunk/src/test/java/org/apache/servicemix/cxfbc/CxfBcProviderTest.java?rev=677083&r1=677082&r2=677083&view=diff
==============================================================================
--- servicemix/components/bindings/servicemix-cxf-bc/trunk/src/test/java/org/apache/servicemix/cxfbc/CxfBcProviderTest.java (original)
+++ servicemix/components/bindings/servicemix-cxf-bc/trunk/src/test/java/org/apache/servicemix/cxfbc/CxfBcProviderTest.java Tue Jul 15 16:10:45 2008
@@ -89,7 +89,7 @@
client.sendSync(io);
assertTrue(new SourceTransformer().contentToString(
io.getOutMessage()).indexOf("server is stop") >= 0);
-
+ client.done(io);
}
public void testProvider() throws Exception {
@@ -126,6 +126,7 @@
client.sendSync(io);
assertTrue(new SourceTransformer().contentToString(
io.getOutMessage()).indexOf("Hello ffang 3") >= 0);
+ client.done(io);
//test exception handle
io = client.createInOutExchange();
@@ -143,7 +144,8 @@
client.sendSync(io);
assertTrue(new SourceTransformer().contentToString(
io.getOutMessage()).indexOf("Hello exception test Negative number cant be added!") >= 0);
-
+ client.done(io);
+
//test onway
factory = new JaxWsServerFactoryBean();
@@ -173,7 +175,8 @@
client.sendSync(io);
assertTrue(new SourceTransformer().contentToString(
io.getOutMessage()).indexOf("Hello oneway test oneway") >= 0);
-
+ client.done(io);
+
factory = new JaxWsServerFactoryBean();
factory.setServiceClass(HelloPortType.class);
factory.setServiceBean(new HelloPortTypeImpl());
@@ -201,10 +204,10 @@
+ "</requestType></greetMe>"
+ "</part> "
+ "</message>"));
- client.send(io);
- Thread.sleep(3000);
+ client.sendSync(io);
assertTrue(new SourceTransformer().contentToString(
io.getOutMessage()).indexOf("Hello header test 12345") >= 0);
+ client.done(io);
//test concurrency
io = client.createInOutExchange();
@@ -219,10 +222,10 @@
+ "</requestType></greetMe>"
+ "</part> "
+ "</message>"));
- client.send(io);
- Thread.sleep(3000);
+ client.sendSync(io);
assertTrue(new SourceTransformer().contentToString(
io.getOutMessage()).indexOf("Hello concurrency test 0 2 4 6 8 10 12 14 16 18") >= 0);
+ client.done(io);
// Shutdown CXF Service/Endpoint so that next test doesn't fail.
factory.getBus().shutdown(true);
}