7:15 p.m.
Author: alessio.soldano(a)jboss.com
Date: 2012-06-21 06:15:55 -0400 (Thu, 21 Jun 2012)
New Revision: 16419
Added:
stack/cxf/trunk/modules/testsuite/cxf-tests/src/test/java/org/jboss/test/ws/jaxws/samples/asynch/
stack/cxf/trunk/modules/testsuite/cxf-tests/src/test/java/org/jboss/test/ws/jaxws/samples/asynch/AsynchTestCase.java
stack/cxf/trunk/modules/testsuite/cxf-tests/src/test/java/org/jboss/test/ws/jaxws/samples/asynch/Endpoint.java
stack/cxf/trunk/modules/testsuite/cxf-tests/src/test/java/org/jboss/test/ws/jaxws/samples/asynch/EndpointImpl.java
stack/cxf/trunk/modules/testsuite/cxf-tests/src/test/resources/jaxws/samples/asynch/
stack/cxf/trunk/modules/testsuite/cxf-tests/src/test/resources/jaxws/samples/asynch/WEB-INF/
stack/cxf/trunk/modules/testsuite/cxf-tests/src/test/resources/jaxws/samples/asynch/WEB-INF/web.xml
Modified:
stack/cxf/trunk/modules/testsuite/cxf-tests/scripts/cxf-samples-jars-jaxws.xml
Log:
[JBWS-3523] Adding testcase for server side async with CXF @UseAsynchMethod
Modified: stack/cxf/trunk/modules/testsuite/cxf-tests/scripts/cxf-samples-jars-jaxws.xml
===================================================================
---
stack/cxf/trunk/modules/testsuite/cxf-tests/scripts/cxf-samples-jars-jaxws.xml 2012-06-21
09:14:46 UTC (rev 16418)
+++
stack/cxf/trunk/modules/testsuite/cxf-tests/scripts/cxf-samples-jars-jaxws.xml 2012-06-21
10:15:55 UTC (rev 16419)
@@ -38,6 +38,18 @@
<mkdir dir="${tests.output.dir}/test-libs"/>
+ <!-- jaxws-samples-asynch -->
+ <war
+ warfile="${tests.output.dir}/test-libs/jaxws-samples-asynch.war"
+
webxml="${tests.output.dir}/test-resources/jaxws/samples/asynch/WEB-INF/web.xml">
+ <classes dir="${tests.output.dir}/test-classes">
+ <include
name="org/jboss/test/ws/jaxws/samples/asynch/EndpointImpl*.class"/>
+ </classes>
+ <manifest>
+ <attribute name="Dependencies"
value="org.apache.cxf"/>
+ </manifest>
+ </war>
+
<!-- jaxws-samples-mtom -->
<war
warfile="${tests.output.dir}/test-libs/jaxws-samples-mtom.war"
Added:
stack/cxf/trunk/modules/testsuite/cxf-tests/src/test/java/org/jboss/test/ws/jaxws/samples/asynch/AsynchTestCase.java
===================================================================
---
stack/cxf/trunk/modules/testsuite/cxf-tests/src/test/java/org/jboss/test/ws/jaxws/samples/asynch/AsynchTestCase.java
(rev 0)
+++
stack/cxf/trunk/modules/testsuite/cxf-tests/src/test/java/org/jboss/test/ws/jaxws/samples/asynch/AsynchTestCase.java 2012-06-21
10:15:55 UTC (rev 16419)
@@ -0,0 +1,97 @@
+/*
+ * JBoss, Home of Professional Open Source.
+ * Copyright 2012, Red Hat Middleware LLC, and individual contributors
+ * as indicated by the @author tags. See the copyright.txt file in the
+ * distribution for a full listing of individual contributors.
+ *
+ * This is free software; you can redistribute it and/or modify it
+ * under the terms of the GNU Lesser General Public License as
+ * published by the Free Software Foundation; either version 2.1 of
+ * the License, or (at your option) any later version.
+ *
+ * This software is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
+ * Lesser General Public License for more details.
+ *
+ * You should have received a copy of the GNU Lesser General Public
+ * License along with this software; if not, write to the Free
+ * Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
+ * 02110-1301 USA, or see the FSF site: http://www.fsf.org.
+ */
+package org.jboss.test.ws.jaxws.samples.asynch;
+
+import java.net.URL;
+import java.util.concurrent.Future;
+
+import javax.xml.namespace.QName;
+import javax.xml.ws.AsyncHandler;
+import javax.xml.ws.Response;
+import javax.xml.ws.Service;
+
+import junit.framework.Test;
+
+import org.jboss.wsf.test.JBossWSCXFTestSetup;
+import org.jboss.wsf.test.JBossWSTest;
+
+/**
+ * Asynchronous web services test case (both client and server side async)
+ *
+ * @author alessio.soldano(a)jboss.com
+ * @since 21-Jun-2012
+ */
+public class AsynchTestCase extends JBossWSTest
+{
+ private String endpointAddress = "http://" + getServerHost() +
":8080/jaxws-samples-asynch";
+
+ public static Test suite()
+ {
+ return new JBossWSCXFTestSetup(AsynchTestCase.class,
"jaxws-samples-asynch.war");
+ }
+
+ public void testAsyncEndpoint() throws Exception
+ {
+ QName serviceName = new QName("http://org.jboss.ws/cxf/samples/asynch",
"EndpointImplService");
+ URL wsdlURL = new URL(endpointAddress + "?wsdl");
+ Service service = Service.create(wsdlURL, serviceName);
+ Endpoint proxy = service.getPort(Endpoint.class);
+ final String user = "Kermit";
+ //do something... then get the result
+ assertEquals(user + " (ASYNC)", proxy.echoAsync(user).get());
+ }
+
+ public void testAsyncEndpointUsingHandler() throws Exception
+ {
+ QName serviceName = new QName("http://org.jboss.ws/cxf/samples/asynch",
"EndpointImplService");
+ URL wsdlURL = new URL(endpointAddress + "?wsdl");
+ Service service = Service.create(wsdlURL, serviceName);
+ Endpoint proxy = service.getPort(Endpoint.class);
+ final String user = "Kermit";
+ TestAsyncHandler handler = new TestAsyncHandler();
+ Future<String> future = proxy.echoAsync(user, handler);
+ //do something... then get the result when it's ready
+ while (!future.isDone()) {
+ Thread.sleep(100);
+ }
+ assertEquals(user + " (ASYNC)", handler.getResponse());
+ }
+
+ private class TestAsyncHandler implements AsyncHandler<String> {
+
+ private String res;
+
+ @Override
+ public void handleResponse(Response<String> response) {
+ try {
+ res = response.get();
+ } catch (Exception e) {
+ e.printStackTrace();
+ res = e.getMessage();
+ }
+ }
+
+ public String getResponse() {
+ return res;
+ }
+ }
+}
Added:
stack/cxf/trunk/modules/testsuite/cxf-tests/src/test/java/org/jboss/test/ws/jaxws/samples/asynch/Endpoint.java
===================================================================
---
stack/cxf/trunk/modules/testsuite/cxf-tests/src/test/java/org/jboss/test/ws/jaxws/samples/asynch/Endpoint.java
(rev 0)
+++
stack/cxf/trunk/modules/testsuite/cxf-tests/src/test/java/org/jboss/test/ws/jaxws/samples/asynch/Endpoint.java 2012-06-21
10:15:55 UTC (rev 16419)
@@ -0,0 +1,46 @@
+/*
+ * JBoss, Home of Professional Open Source.
+ * Copyright 2012, Red Hat Middleware LLC, and individual contributors
+ * as indicated by the @author tags. See the copyright.txt file in the
+ * distribution for a full listing of individual contributors.
+ *
+ * This is free software; you can redistribute it and/or modify it
+ * under the terms of the GNU Lesser General Public License as
+ * published by the Free Software Foundation; either version 2.1 of
+ * the License, or (at your option) any later version.
+ *
+ * This software is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
+ * Lesser General Public License for more details.
+ *
+ * You should have received a copy of the GNU Lesser General Public
+ * License along with this software; if not, write to the Free
+ * Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
+ * 02110-1301 USA, or see the FSF site: http://www.fsf.org.
+ */
+package org.jboss.test.ws.jaxws.samples.asynch;
+
+import java.util.concurrent.Future;
+
+import javax.jws.WebMethod;
+import javax.jws.WebService;
+import javax.jws.soap.SOAPBinding;
+import javax.xml.ws.AsyncHandler;
+import javax.xml.ws.Response;
+
+@WebService(name = "EndpointService", targetNamespace =
"http://org.jboss.ws/cxf/samples/asynch")
+@SOAPBinding(style = SOAPBinding.Style.DOCUMENT, use = SOAPBinding.Use.LITERAL,
parameterStyle = SOAPBinding.ParameterStyle.WRAPPED)
+public interface Endpoint
+{
+ @WebMethod
+ public String echo(String user);
+
+ //The following methods are added (or generated by wsconsume) for the sake of using
asynch jaxws client only
+
+ @WebMethod(operationName = "echo")
+ public Response<String> echoAsync(String user);
+
+ @WebMethod(operationName = "echo")
+ public Future<String> echoAsync(String user, AsyncHandler<String>
handler);
+}
Added:
stack/cxf/trunk/modules/testsuite/cxf-tests/src/test/java/org/jboss/test/ws/jaxws/samples/asynch/EndpointImpl.java
===================================================================
---
stack/cxf/trunk/modules/testsuite/cxf-tests/src/test/java/org/jboss/test/ws/jaxws/samples/asynch/EndpointImpl.java
(rev 0)
+++
stack/cxf/trunk/modules/testsuite/cxf-tests/src/test/java/org/jboss/test/ws/jaxws/samples/asynch/EndpointImpl.java 2012-06-21
10:15:55 UTC (rev 16419)
@@ -0,0 +1,109 @@
+/*
+ * JBoss, Home of Professional Open Source.
+ * Copyright 2012, Red Hat Middleware LLC, and individual contributors
+ * as indicated by the @author tags. See the copyright.txt file in the
+ * distribution for a full listing of individual contributors.
+ *
+ * This is free software; you can redistribute it and/or modify it
+ * under the terms of the GNU Lesser General Public License as
+ * published by the Free Software Foundation; either version 2.1 of
+ * the License, or (at your option) any later version.
+ *
+ * This software is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
+ * Lesser General Public License for more details.
+ *
+ * You should have received a copy of the GNU Lesser General Public
+ * License along with this software; if not, write to the Free
+ * Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
+ * 02110-1301 USA, or see the FSF site: http://www.fsf.org.
+ */
+package org.jboss.test.ws.jaxws.samples.asynch;
+
+import java.util.Map;
+import java.util.concurrent.ExecutionException;
+import java.util.concurrent.Future;
+import java.util.concurrent.TimeUnit;
+import java.util.concurrent.TimeoutException;
+
+import javax.jws.WebService;
+import javax.jws.soap.SOAPBinding;
+import javax.xml.ws.AsyncHandler;
+
+import org.apache.cxf.annotations.UseAsyncMethod;
+
+@WebService(name = "EndpointService", targetNamespace =
"http://org.jboss.ws/cxf/samples/asynch")
+@SOAPBinding(style = SOAPBinding.Style.DOCUMENT, use = SOAPBinding.Use.LITERAL,
parameterStyle = SOAPBinding.ParameterStyle.BARE)
+public class EndpointImpl
+{
+ //be sure to add dependency on org.apache.cxf module for @UseAsyncMethod annotation to
be resolved
+ @UseAsyncMethod //.. if supported by underlying container
+ public String echo(String user)
+ {
+ System.out.println("user: " + user);
+ return user + " (SYNC)";
+ }
+
+ //this method is not actually converted into an operation in the wsdl contract, as
it's up to the
+ //Apache CXF implementation to redirect invocation to this when the @UseAsyncMethod
annotated
+ //echo method is called.
+ public Future<?> echoAsync(final String user, final AsyncHandler<String>
asyncHandler)
+ {
+ final ServerAsyncResponse<String> r = new
ServerAsyncResponse<String>();
+ //here the business method would likely enqueue the request for a long running
process;
+ //then the queue might for instance be consumed by a different thread pool...
+ new Thread() {
+ public void run() {
+ r.set(user + " (ASYNC)");
+ System.out.println("Responding on background thread...");
+ asyncHandler.handleResponse(r);
+ }
+ }.start();
+ //the web container thread proceeds further and the container is able to serve new
web requests with it
+ return r;
+ }
+
+ //helper class
+ private class ServerAsyncResponse<T> implements javax.xml.ws.Response<T>
{
+ T value;
+ boolean done;
+ Throwable throwable;
+
+ /**
+ * Currently unused
+ */
+ public boolean cancel(boolean mayInterruptIfRunning) {
+ return false;
+ }
+ /**
+ * Currently unused
+ */
+ public boolean isCancelled() {
+ return false;
+ }
+ public boolean isDone() {
+ return done;
+ }
+ public void set(T t) {
+ value = t;
+ done = true;
+ }
+ public T get() throws InterruptedException, ExecutionException {
+ if (throwable != null) {
+ throw new ExecutionException(throwable);
+ }
+ return value;
+ }
+ public T get(long timeout, TimeUnit unit)
+ throws InterruptedException, ExecutionException, TimeoutException {
+ return value;
+ }
+ /**
+ * Currently unused
+ */
+ public Map<String, Object> getContext() {
+ return null;
+ }
+ }
+}
Added:
stack/cxf/trunk/modules/testsuite/cxf-tests/src/test/resources/jaxws/samples/asynch/WEB-INF/web.xml
===================================================================
---
stack/cxf/trunk/modules/testsuite/cxf-tests/src/test/resources/jaxws/samples/asynch/WEB-INF/web.xml
(rev 0)
+++
stack/cxf/trunk/modules/testsuite/cxf-tests/src/test/resources/jaxws/samples/asynch/WEB-INF/web.xml 2012-06-21
10:15:55 UTC (rev 16419)
@@ -0,0 +1,16 @@
+<?xml version="1.0" encoding="UTF-8"?>
+
+<web-app
+ version="3.0" xmlns="http://java.sun.com/xml/ns/javaee"
+ xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+ xsi:schemaLocation="http://java.sun.com/xml/ns/javaee
http://java.sun.com/xml/ns/javaee/web-app_3_0.xsd">
+ <servlet>
+ <servlet-name>AsynchService</servlet-name>
+
<servlet-class>org.jboss.test.ws.jaxws.samples.asynch.EndpointImpl</servlet-class>
+ <async-supported>true</async-supported>
+ </servlet>
+ <servlet-mapping>
+ <servlet-name>AsynchService</servlet-name>
+ <url-pattern>/*</url-pattern>
+ </servlet-mapping>
+</web-app>