[jbossws-commits] JBossWS SVN: r19350 - stack/cxf/branches/arquillian/modules/testsuite/shared-tests/src/test/java/org/jboss/test/ws/jaxws/samples/asynchronous.
jbossws-commits at lists.jboss.org
jbossws-commits at lists.jboss.org
Thu Jan 8 15:33:47 EST 2015
Author: asoldano
Date: 2015-01-08 15:33:47 -0500 (Thu, 08 Jan 2015)
New Revision: 19350
Added:
stack/cxf/branches/arquillian/modules/testsuite/shared-tests/src/test/java/org/jboss/test/ws/jaxws/samples/asynchronous/AsynchronousTestCase.java
Removed:
stack/cxf/branches/arquillian/modules/testsuite/shared-tests/src/test/java/org/jboss/test/ws/jaxws/samples/asynchronous/AsynchronousDispatchTestCase.java
stack/cxf/branches/arquillian/modules/testsuite/shared-tests/src/test/java/org/jboss/test/ws/jaxws/samples/asynchronous/AsynchronousProxyTestCase.java
Log:
Fix deployment name clash (we can't have two or more tests relying on the same deployment as that breaks parallel test execution)
Deleted: stack/cxf/branches/arquillian/modules/testsuite/shared-tests/src/test/java/org/jboss/test/ws/jaxws/samples/asynchronous/AsynchronousDispatchTestCase.java
===================================================================
--- stack/cxf/branches/arquillian/modules/testsuite/shared-tests/src/test/java/org/jboss/test/ws/jaxws/samples/asynchronous/AsynchronousDispatchTestCase.java 2015-01-08 17:15:27 UTC (rev 19349)
+++ stack/cxf/branches/arquillian/modules/testsuite/shared-tests/src/test/java/org/jboss/test/ws/jaxws/samples/asynchronous/AsynchronousDispatchTestCase.java 2015-01-08 20:33:47 UTC (rev 19350)
@@ -1,137 +0,0 @@
-/*
- * JBoss, Home of Professional Open Source.
- * Copyright 2006, 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.asynchronous;
-
-import java.io.File;
-import java.io.IOException;
-import java.io.StringReader;
-import java.net.MalformedURLException;
-import java.net.URL;
-import java.util.concurrent.Future;
-import java.util.concurrent.TimeUnit;
-
-import javax.xml.namespace.QName;
-import javax.xml.transform.Source;
-import javax.xml.transform.stream.StreamSource;
-import javax.xml.ws.AsyncHandler;
-import javax.xml.ws.Dispatch;
-import javax.xml.ws.Response;
-import javax.xml.ws.Service;
-import javax.xml.ws.Service.Mode;
-
-import org.jboss.arquillian.container.test.api.Deployment;
-import org.jboss.arquillian.container.test.api.RunAsClient;
-import org.jboss.arquillian.junit.Arquillian;
-import org.jboss.arquillian.test.api.ArquillianResource;
-import org.jboss.shrinkwrap.api.ShrinkWrap;
-import org.jboss.shrinkwrap.api.spec.WebArchive;
-import org.jboss.ws.common.DOMUtils;
-import org.jboss.wsf.test.JBossWSTest;
-import org.jboss.wsf.test.JBossWSTestHelper;
-import org.junit.Test;
-import org.junit.runner.RunWith;
-import org.w3c.dom.Element;
-
-/**
- * Test JAXWS asynchrous dispatch
- *
- * @author Thomas.Diesler at jboss.org
- * @since 12-Aug-2006
- */
- at RunWith(Arquillian.class)
-public class AsynchronousDispatchTestCase extends JBossWSTest
-{
- private final String targetNS = "http://org.jboss.ws/jaxws/asynchronous";
- private final String reqPayload = "<ns2:echo xmlns:ns2='" + targetNS + "'><String_1>Hello</String_1></ns2:echo>";
- private Exception handlerException;
- private boolean asyncHandlerCalled;
-
- @ArquillianResource
- private URL baseURL;
-
- @Deployment(testable = false)
- public static WebArchive createDeployment() {
- WebArchive archive = ShrinkWrap.create(WebArchive.class, "jaxws-samples-asynchronous.war");
- archive
- .addManifest()
- .addClass(org.jboss.test.ws.jaxws.samples.asynchronous.Endpoint.class)
- .addClass(org.jboss.test.ws.jaxws.samples.asynchronous.EndpointBean.class)
- .setWebXML(new File(JBossWSTestHelper.getTestResourcesDir() + "/jaxws/samples/asynchronous/WEB-INF/web.xml"));
- return archive;
- }
-
- @Test
- @RunAsClient
- public void testInvokeAsynch() throws Exception
- {
- Source reqObj = new StreamSource(new StringReader(reqPayload));
- Response<Source> response = createDispatch().invokeAsync(reqObj);
- verifyResponse(response.get(3000, TimeUnit.MILLISECONDS));
- }
-
- @Test
- @RunAsClient
- public void testInvokeAsynchHandler() throws Exception
- {
- AsyncHandler<Source> handler = new AsyncHandler<Source>()
- {
- @Override
- public void handleResponse(Response<Source> response)
- {
- try
- {
- verifyResponse(response.get());
- asyncHandlerCalled = true;
- }
- catch (Exception ex)
- {
- handlerException = ex;
- }
- }
- };
- StreamSource reqObj = new StreamSource(new StringReader(reqPayload));
- Future<?> future = createDispatch().invokeAsync(reqObj, handler);
- future.get(1000, TimeUnit.MILLISECONDS);
-
- if (handlerException != null)
- throw handlerException;
-
- assertTrue("Async handler called", asyncHandlerCalled);
- }
-
- private Dispatch<Source> createDispatch() throws MalformedURLException
- {
- URL wsdlURL = new URL(baseURL + "?wsdl");
- QName serviceName = new QName(targetNS, "EndpointBeanService");
- QName portName = new QName(targetNS, "EndpointPort");
- Service service = Service.create(wsdlURL, serviceName);
- return service.createDispatch(portName, Source.class, Mode.PAYLOAD);
- }
-
- private void verifyResponse(Source result) throws IOException
- {
- Element docElement = DOMUtils.sourceToElement(result);
- Element retElement = DOMUtils.getFirstChildElement(docElement);
- assertEquals("result", retElement.getNodeName());
- assertEquals("Hello", retElement.getTextContent());
- }
-}
Deleted: stack/cxf/branches/arquillian/modules/testsuite/shared-tests/src/test/java/org/jboss/test/ws/jaxws/samples/asynchronous/AsynchronousProxyTestCase.java
===================================================================
--- stack/cxf/branches/arquillian/modules/testsuite/shared-tests/src/test/java/org/jboss/test/ws/jaxws/samples/asynchronous/AsynchronousProxyTestCase.java 2015-01-08 17:15:27 UTC (rev 19349)
+++ stack/cxf/branches/arquillian/modules/testsuite/shared-tests/src/test/java/org/jboss/test/ws/jaxws/samples/asynchronous/AsynchronousProxyTestCase.java 2015-01-08 20:33:47 UTC (rev 19350)
@@ -1,137 +0,0 @@
-/*
- * JBoss, Home of Professional Open Source.
- * Copyright 2006, 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.asynchronous;
-
-import java.io.File;
-import java.net.MalformedURLException;
-import java.net.URL;
-import java.util.concurrent.Future;
-import java.util.concurrent.TimeUnit;
-
-import javax.xml.namespace.QName;
-import javax.xml.ws.AsyncHandler;
-import javax.xml.ws.Response;
-import javax.xml.ws.Service;
-
-import org.jboss.arquillian.container.test.api.Deployment;
-import org.jboss.arquillian.container.test.api.RunAsClient;
-import org.jboss.arquillian.junit.Arquillian;
-import org.jboss.arquillian.test.api.ArquillianResource;
-import org.jboss.shrinkwrap.api.ShrinkWrap;
-import org.jboss.shrinkwrap.api.spec.WebArchive;
-import org.jboss.wsf.test.JBossWSTest;
-import org.jboss.wsf.test.JBossWSTestHelper;
-import org.junit.Test;
-import org.junit.runner.RunWith;
-
-/**
- * Test JAXWS asynchrous proxy
- *
- * @author Thomas.Diesler at jboss.org
- * @since 12-Aug-2006
- */
- at RunWith(Arquillian.class)
-public class AsynchronousProxyTestCase extends JBossWSTest
-{
- private final String targetNS = "http://org.jboss.ws/jaxws/asynchronous";
- private Exception handlerException;
- private boolean asyncHandlerCalled;
-
- @ArquillianResource
- private URL baseURL;
-
- @Deployment(testable = false)
- public static WebArchive createDeployment() {
- WebArchive archive = ShrinkWrap.create(WebArchive.class, "jaxws-samples-asynchronous.war");
- archive
- .addManifest()
- .addClass(org.jboss.test.ws.jaxws.samples.asynchronous.Endpoint.class)
- .addClass(org.jboss.test.ws.jaxws.samples.asynchronous.EndpointBean.class)
- .setWebXML(new File(JBossWSTestHelper.getTestResourcesDir() + "/jaxws/samples/asynchronous/WEB-INF/web.xml"));
- return archive;
- }
-
- @Test
- @RunAsClient
- public void testInvokeSync() throws Exception
- {
- Endpoint port = createProxy();
- String retStr = port.echo("Hello");
- assertEquals("Hello", retStr);
- }
-
- @Test
- @RunAsClient
- public void testInvokeAsync() throws Exception
- {
- Endpoint port = createProxy();
- Response<String> response = port.echoAsync("Async");
-
- // access future
- String retStr = response.get();
- assertEquals("Async", retStr);
- }
-
- @Test
- @RunAsClient
- public void testInvokeAsyncHandler() throws Exception
- {
- AsyncHandler<String> handler = new AsyncHandler<String>()
- {
- @Override
- public void handleResponse(Response<String> response)
- {
- try
- {
- System.out.println("AsyncHandler.handleResponse() method called");
- String retStr = response.get(5000, TimeUnit.MILLISECONDS);
- assertEquals("Hello", retStr);
- asyncHandlerCalled = true;
- }
- catch (Exception ex)
- {
- handlerException = ex;
- }
- }
- };
-
- Endpoint port = createProxy();
- Future<?> future = port.echoAsync("Hello", handler);
- long start = System.currentTimeMillis();
- future.get(5000, TimeUnit.MILLISECONDS);
- long end = System.currentTimeMillis();
- System.out.println("Time spent in future.get() was " + (end - start) + "milliseconds");
-
- if (handlerException != null)
- throw handlerException;
-
- assertTrue("Async handler called", asyncHandlerCalled);
- }
-
- private Endpoint createProxy() throws MalformedURLException
- {
- URL wsdlURL = new URL(baseURL + "?wsdl");
- QName serviceName = new QName(targetNS, "EndpointBeanService");
- Service service = Service.create(wsdlURL, serviceName);
- return service.getPort(Endpoint.class);
- }
-}
Added: stack/cxf/branches/arquillian/modules/testsuite/shared-tests/src/test/java/org/jboss/test/ws/jaxws/samples/asynchronous/AsynchronousTestCase.java
===================================================================
--- stack/cxf/branches/arquillian/modules/testsuite/shared-tests/src/test/java/org/jboss/test/ws/jaxws/samples/asynchronous/AsynchronousTestCase.java (rev 0)
+++ stack/cxf/branches/arquillian/modules/testsuite/shared-tests/src/test/java/org/jboss/test/ws/jaxws/samples/asynchronous/AsynchronousTestCase.java 2015-01-08 20:33:47 UTC (rev 19350)
@@ -0,0 +1,206 @@
+/*
+ * JBoss, Home of Professional Open Source.
+ * Copyright 2015, 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.asynchronous;
+
+import java.io.File;
+import java.io.IOException;
+import java.io.StringReader;
+import java.net.MalformedURLException;
+import java.net.URL;
+import java.util.concurrent.Future;
+import java.util.concurrent.TimeUnit;
+
+import javax.xml.namespace.QName;
+import javax.xml.transform.Source;
+import javax.xml.transform.stream.StreamSource;
+import javax.xml.ws.AsyncHandler;
+import javax.xml.ws.Dispatch;
+import javax.xml.ws.Response;
+import javax.xml.ws.Service;
+import javax.xml.ws.Service.Mode;
+
+import org.jboss.arquillian.container.test.api.Deployment;
+import org.jboss.arquillian.container.test.api.RunAsClient;
+import org.jboss.arquillian.junit.Arquillian;
+import org.jboss.arquillian.test.api.ArquillianResource;
+import org.jboss.shrinkwrap.api.ShrinkWrap;
+import org.jboss.shrinkwrap.api.spec.WebArchive;
+import org.jboss.ws.common.DOMUtils;
+import org.jboss.wsf.test.JBossWSTest;
+import org.jboss.wsf.test.JBossWSTestHelper;
+import org.junit.Test;
+import org.junit.runner.RunWith;
+import org.w3c.dom.Element;
+
+/**
+ * Test JAXWS asynchrous proxy
+ *
+ * @author Thomas.Diesler at jboss.org
+ * @author alessio.soldano at jboss.com
+ * @since 12-Aug-2006
+ */
+ at RunWith(Arquillian.class)
+public class AsynchronousTestCase extends JBossWSTest
+{
+ private final String targetNS = "http://org.jboss.ws/jaxws/asynchronous";
+ private Exception handlerProxyException;
+ private boolean asyncHandlerProxyCalled;
+
+ private final String reqPayload = "<ns2:echo xmlns:ns2='" + targetNS + "'><String_1>Hello</String_1></ns2:echo>";
+ private Exception handlerDispatchException;
+ private boolean asyncHandlerDispatchCalled;
+
+ @ArquillianResource
+ private URL baseURL;
+
+ @Deployment(testable = false)
+ public static WebArchive createDeployment() {
+ WebArchive archive = ShrinkWrap.create(WebArchive.class, "jaxws-samples-asynchronous.war");
+ archive
+ .addManifest()
+ .addClass(org.jboss.test.ws.jaxws.samples.asynchronous.Endpoint.class)
+ .addClass(org.jboss.test.ws.jaxws.samples.asynchronous.EndpointBean.class)
+ .setWebXML(new File(JBossWSTestHelper.getTestResourcesDir() + "/jaxws/samples/asynchronous/WEB-INF/web.xml"));
+ return archive;
+ }
+
+ @Test
+ @RunAsClient
+ public void testInvokeSync() throws Exception
+ {
+ Endpoint port = createProxy();
+ String retStr = port.echo("Hello");
+ assertEquals("Hello", retStr);
+ }
+
+ @Test
+ @RunAsClient
+ public void testInvokeAsync() throws Exception
+ {
+ Endpoint port = createProxy();
+ Response<String> response = port.echoAsync("Async");
+
+ // access future
+ String retStr = response.get();
+ assertEquals("Async", retStr);
+ }
+
+ @Test
+ @RunAsClient
+ public void testInvokeAsyncHandler() throws Exception
+ {
+ AsyncHandler<String> handler = new AsyncHandler<String>()
+ {
+ @Override
+ public void handleResponse(Response<String> response)
+ {
+ try
+ {
+ System.out.println("AsyncHandler.handleResponse() method called");
+ String retStr = response.get(5000, TimeUnit.MILLISECONDS);
+ assertEquals("Hello", retStr);
+ asyncHandlerProxyCalled = true;
+ }
+ catch (Exception ex)
+ {
+ handlerProxyException = ex;
+ }
+ }
+ };
+
+ Endpoint port = createProxy();
+ Future<?> future = port.echoAsync("Hello", handler);
+ long start = System.currentTimeMillis();
+ future.get(5000, TimeUnit.MILLISECONDS);
+ long end = System.currentTimeMillis();
+ System.out.println("Time spent in future.get() was " + (end - start) + "milliseconds");
+
+ if (handlerProxyException != null)
+ throw handlerProxyException;
+
+ assertTrue("Async handler called", asyncHandlerProxyCalled);
+ }
+
+ private Endpoint createProxy() throws MalformedURLException
+ {
+ URL wsdlURL = new URL(baseURL + "?wsdl");
+ QName serviceName = new QName(targetNS, "EndpointBeanService");
+ Service service = Service.create(wsdlURL, serviceName);
+ return service.getPort(Endpoint.class);
+ }
+
+ @Test
+ @RunAsClient
+ public void testInvokeAsyncDispatch() throws Exception
+ {
+ Source reqObj = new StreamSource(new StringReader(reqPayload));
+ Response<Source> response = createDispatch().invokeAsync(reqObj);
+ verifyResponse(response.get(3000, TimeUnit.MILLISECONDS));
+ }
+
+ @Test
+ @RunAsClient
+ public void testInvokeAsyncDispatchHandler() throws Exception
+ {
+ AsyncHandler<Source> handler = new AsyncHandler<Source>()
+ {
+ @Override
+ public void handleResponse(Response<Source> response)
+ {
+ try
+ {
+ verifyResponse(response.get());
+ asyncHandlerDispatchCalled = true;
+ }
+ catch (Exception ex)
+ {
+ handlerDispatchException = ex;
+ }
+ }
+ };
+ StreamSource reqObj = new StreamSource(new StringReader(reqPayload));
+ Future<?> future = createDispatch().invokeAsync(reqObj, handler);
+ future.get(1000, TimeUnit.MILLISECONDS);
+
+ if (handlerDispatchException != null)
+ throw handlerDispatchException;
+
+ assertTrue("Async handler called", asyncHandlerDispatchCalled);
+ }
+
+ private Dispatch<Source> createDispatch() throws MalformedURLException
+ {
+ URL wsdlURL = new URL(baseURL + "?wsdl");
+ QName serviceName = new QName(targetNS, "EndpointBeanService");
+ QName portName = new QName(targetNS, "EndpointPort");
+ Service service = Service.create(wsdlURL, serviceName);
+ return service.createDispatch(portName, Source.class, Mode.PAYLOAD);
+ }
+
+ private void verifyResponse(Source result) throws IOException
+ {
+ Element docElement = DOMUtils.sourceToElement(result);
+ Element retElement = DOMUtils.getFirstChildElement(docElement);
+ assertEquals("result", retElement.getNodeName());
+ assertEquals("Hello", retElement.getTextContent());
+ }
+}
Property changes on: stack/cxf/branches/arquillian/modules/testsuite/shared-tests/src/test/java/org/jboss/test/ws/jaxws/samples/asynchronous/AsynchronousTestCase.java
___________________________________________________________________
Added: svn:keywords
+ Rev Date
Added: svn:eol-style
+ native
More information about the jbossws-commits
mailing list