cxf-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From dk...@apache.org
Subject svn commit: r1133913 [9/13] - in /cxf/trunk: rt/core/src/test/java/org/apache/cxf/endpoint/ rt/frontend/jaxrs/src/main/java/org/apache/cxf/jaxrs/ext/search/client/ rt/frontend/jaxrs/src/test/java/org/apache/cxf/jaxrs/ext/search/client/ rt/frontend/jaxw...
Date Thu, 09 Jun 2011 15:08:27 GMT
Propchange: cxf/trunk/systests/transport-jms/src/test/java/org/apache/cxf/systest/jms/JMSClientServerTest.java
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: cxf/trunk/systests/transport-jms/src/test/java/org/apache/cxf/systest/jms/JMSClientServerTest.java
------------------------------------------------------------------------------
    svn:keywords = Rev Date

Modified: cxf/trunk/systests/transport-jms/src/test/java/org/apache/cxf/systest/jms/JMSClients.xml
URL: http://svn.apache.org/viewvc/cxf/trunk/systests/transport-jms/src/test/java/org/apache/cxf/systest/jms/JMSClients.xml?rev=1133913&r1=1133912&r2=1133913&view=diff
==============================================================================
--- cxf/trunk/systests/transport-jms/src/test/java/org/apache/cxf/systest/jms/JMSClients.xml (original)
+++ cxf/trunk/systests/transport-jms/src/test/java/org/apache/cxf/systest/jms/JMSClients.xml Thu Jun  9 15:08:22 2011
@@ -1,64 +1,64 @@
-<?xml version="1.0" encoding="UTF-8"?>
-<!--
-  Licensed to the Apache Software Foundation (ASF) under one
-  or more contributor license agreements. See the NOTICE file
-  distributed with this work for additional information
-  regarding copyright ownership. The ASF licenses this file
-  to you under the Apache License, Version 2.0 (the
-  "License"); you may not use this file except in compliance
-  with the License. You may obtain a copy of the License at
-
-  http://www.apache.org/licenses/LICENSE-2.0
-
-  Unless required by applicable law or agreed to in writing,
-  software distributed under the License is distributed on an
-  "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
-  KIND, either express or implied. See the License for the
-  specific language governing permissions and limitations
-  under the License.
--->
-
-<beans xmlns="http://www.springframework.org/schema/beans"
-      xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
-      xmlns:jaxws="http://cxf.apache.org/jaxws"
-      xsi:schemaLocation="
-http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd
-http://cxf.apache.org/jaxws http://cxf.apache.org/schemas/jaxws.xsd">
-
-    <import resource="classpath:META-INF/cxf/cxf.xml"/>
-    <!--jaxws:endpoint
-        id="GreerterJMSService"
-        implementor="org.apache.cxf.systest.jms.GreeterImplQueueOneWay"
-        address="http://cxf.apache.org/transports/jms" /-->
-        
-    <jaxws:client id="jmsRPCClient" 
-    	serviceClass="org.apache.cxf.hello_world_jms.HelloWorldPortType"    
-    	serviceName="s:HelloWorldService"
-    	endpointName="s:HelloWorldPort"    	
-    	xmlns:s="http://cxf.apache.org/hello_world_jms"
-    	wsdlLocation="classpath:wsdl/jms_test.wsdl"/>       
-    		   
-    
-    <bean id="jmsQueueOneWayServiceClient" class="org.apache.cxf.hello_world_jms.HelloWorldOneWayPort"
-       factory-bean="jmsQueueOneWayServiceClientFactory"
- 	   factory-method="create"/>
-
-    <bean id="jmsQueueOneWayServiceClientFactory"
-          class="org.apache.cxf.jaxws.JaxWsProxyFactoryBean">
-          <property name="serviceClass" value="org.apache.cxf.hello_world_jms.HelloWorldOneWayPort"/>
-          <property name="wsdlURL" value="classpath:wsdl/jms_test.wsdl" />
-          <property name="serviceName">
-              <bean class="javax.xml.namespace.QName" scope="prototype">
-                  <constructor-arg value="http://cxf.apache.org/hello_world_jms" />
-                  <constructor-arg value="HelloWorldOneWayQueueService" />
-              </bean>
-          </property>
-          <property name="endpointName">
-              <bean class="javax.xml.namespace.QName" scope="prototype">
-                  <constructor-arg value="http://cxf.apache.org/hello_world_jms" />
-                  <constructor-arg value="HelloWorldOneWayQueuePort" />
-              </bean>
-          </property>
-   </bean>
-   
+<?xml version="1.0" encoding="UTF-8"?>
+<!--
+  Licensed to the Apache Software Foundation (ASF) under one
+  or more contributor license agreements. See the NOTICE file
+  distributed with this work for additional information
+  regarding copyright ownership. The ASF licenses this file
+  to you under the Apache License, Version 2.0 (the
+  "License"); you may not use this file except in compliance
+  with the License. You may obtain a copy of the License at
+
+  http://www.apache.org/licenses/LICENSE-2.0
+
+  Unless required by applicable law or agreed to in writing,
+  software distributed under the License is distributed on an
+  "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+  KIND, either express or implied. See the License for the
+  specific language governing permissions and limitations
+  under the License.
+-->
+
+<beans xmlns="http://www.springframework.org/schema/beans"
+      xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+      xmlns:jaxws="http://cxf.apache.org/jaxws"
+      xsi:schemaLocation="
+http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd
+http://cxf.apache.org/jaxws http://cxf.apache.org/schemas/jaxws.xsd">
+
+    <import resource="classpath:META-INF/cxf/cxf.xml"/>
+    <!--jaxws:endpoint
+        id="GreerterJMSService"
+        implementor="org.apache.cxf.systest.jms.GreeterImplQueueOneWay"
+        address="http://cxf.apache.org/transports/jms" /-->
+        
+    <jaxws:client id="jmsRPCClient" 
+    	serviceClass="org.apache.cxf.hello_world_jms.HelloWorldPortType"    
+    	serviceName="s:HelloWorldService"
+    	endpointName="s:HelloWorldPort"    	
+    	xmlns:s="http://cxf.apache.org/hello_world_jms"
+    	wsdlLocation="classpath:wsdl/jms_test.wsdl"/>       
+    		   
+    
+    <bean id="jmsQueueOneWayServiceClient" class="org.apache.cxf.hello_world_jms.HelloWorldOneWayPort"
+       factory-bean="jmsQueueOneWayServiceClientFactory"
+ 	   factory-method="create"/>
+
+    <bean id="jmsQueueOneWayServiceClientFactory"
+          class="org.apache.cxf.jaxws.JaxWsProxyFactoryBean">
+          <property name="serviceClass" value="org.apache.cxf.hello_world_jms.HelloWorldOneWayPort"/>
+          <property name="wsdlURL" value="classpath:wsdl/jms_test.wsdl" />
+          <property name="serviceName">
+              <bean class="javax.xml.namespace.QName" scope="prototype">
+                  <constructor-arg value="http://cxf.apache.org/hello_world_jms" />
+                  <constructor-arg value="HelloWorldOneWayQueueService" />
+              </bean>
+          </property>
+          <property name="endpointName">
+              <bean class="javax.xml.namespace.QName" scope="prototype">
+                  <constructor-arg value="http://cxf.apache.org/hello_world_jms" />
+                  <constructor-arg value="HelloWorldOneWayQueuePort" />
+              </bean>
+          </property>
+   </bean>
+   
  </beans>  
\ No newline at end of file

Propchange: cxf/trunk/systests/transport-jms/src/test/java/org/apache/cxf/systest/jms/JMSClients.xml
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: cxf/trunk/systests/transport-jms/src/test/java/org/apache/cxf/systest/jms/JMSClients.xml
------------------------------------------------------------------------------
    svn:keywords = Rev Date

Propchange: cxf/trunk/systests/transport-jms/src/test/java/org/apache/cxf/systest/jms/JMSClients.xml
------------------------------------------------------------------------------
    svn:mime-type = text/xml

Modified: cxf/trunk/systests/transport-jms/src/test/java/org/apache/cxf/systest/jms/JMSMTOMImpl.java
URL: http://svn.apache.org/viewvc/cxf/trunk/systests/transport-jms/src/test/java/org/apache/cxf/systest/jms/JMSMTOMImpl.java?rev=1133913&r1=1133912&r2=1133913&view=diff
==============================================================================
--- cxf/trunk/systests/transport-jms/src/test/java/org/apache/cxf/systest/jms/JMSMTOMImpl.java (original)
+++ cxf/trunk/systests/transport-jms/src/test/java/org/apache/cxf/systest/jms/JMSMTOMImpl.java Thu Jun  9 15:08:22 2011
@@ -1,45 +1,45 @@
-/**
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied. See the License for the
- * specific language governing permissions and limitations
- * under the License.
- */
-package org.apache.cxf.systest.jms;
-
-import java.io.IOException;
-
-import javax.activation.DataHandler;
-import javax.jws.WebService;
-import javax.xml.ws.Holder;
-
-import org.apache.cxf.jms_mtom.JMSMTOMPortType;
-
-@WebService(serviceName = "JMSMTOMService", 
-            portName = "JMSMTOMPortType", 
-            endpointInterface = "org.apache.cxf.jms_mtom.JMSMTOMPortType", 
-            targetNamespace = "http://cxf.apache.org/jms_mtom", 
-            wsdlLocation = "testutils/jms_test_mtom.wsdl")
-public class JMSMTOMImpl implements JMSMTOMPortType {
-
-    public void testDataHandler(Holder<String> name, Holder<DataHandler> attachinfo) {
-        System.out.println(name.value);
-        try {
-            System.out.println(attachinfo.value.getInputStream().available());
-        } catch (IOException e) {
-            e.printStackTrace();
-        }
-        System.out.println("TestDataHandler End");
-    }
-}
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+package org.apache.cxf.systest.jms;
+
+import java.io.IOException;
+
+import javax.activation.DataHandler;
+import javax.jws.WebService;
+import javax.xml.ws.Holder;
+
+import org.apache.cxf.jms_mtom.JMSMTOMPortType;
+
+@WebService(serviceName = "JMSMTOMService", 
+            portName = "JMSMTOMPortType", 
+            endpointInterface = "org.apache.cxf.jms_mtom.JMSMTOMPortType", 
+            targetNamespace = "http://cxf.apache.org/jms_mtom", 
+            wsdlLocation = "testutils/jms_test_mtom.wsdl")
+public class JMSMTOMImpl implements JMSMTOMPortType {
+
+    public void testDataHandler(Holder<String> name, Holder<DataHandler> attachinfo) {
+        System.out.println(name.value);
+        try {
+            System.out.println(attachinfo.value.getInputStream().available());
+        } catch (IOException e) {
+            e.printStackTrace();
+        }
+        System.out.println("TestDataHandler End");
+    }
+}

Propchange: cxf/trunk/systests/transport-jms/src/test/java/org/apache/cxf/systest/jms/JMSMTOMImpl.java
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: cxf/trunk/systests/transport-jms/src/test/java/org/apache/cxf/systest/jms/JMSMTOMImpl.java
------------------------------------------------------------------------------
    svn:keywords = Rev Date

Modified: cxf/trunk/systests/transport-jms/src/test/java/org/apache/cxf/systest/jms/JmsDestPubSubImpl.java
URL: http://svn.apache.org/viewvc/cxf/trunk/systests/transport-jms/src/test/java/org/apache/cxf/systest/jms/JmsDestPubSubImpl.java?rev=1133913&r1=1133912&r2=1133913&view=diff
==============================================================================
--- cxf/trunk/systests/transport-jms/src/test/java/org/apache/cxf/systest/jms/JmsDestPubSubImpl.java (original)
+++ cxf/trunk/systests/transport-jms/src/test/java/org/apache/cxf/systest/jms/JmsDestPubSubImpl.java Thu Jun  9 15:08:22 2011
@@ -1,40 +1,40 @@
-/**
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied. See the License for the
- * specific language governing permissions and limitations
- * under the License.
- */
-package org.apache.cxf.systest.jms;
-
-import javax.jws.WebService;
-
-import org.apache.cxf.hello_world_jms.HelloWorldPubSubPort;
-
-
-@WebService(serviceName = "JmsDestinationPubSubService", 
-            portName = "JmsDestinationPubSubPort", 
-            endpointInterface = "org.apache.cxf.hello_world_jms.HelloWorldPubSubPort",
-            targetNamespace = "http://cxf.apache.org/hello_world_jms",
-            wsdlLocation = "testutils/jms_test.wsdl")
-
-public class JmsDestPubSubImpl implements HelloWorldPubSubPort {
-
-    public void greetMeOneWay(String stringParam0) {
-        // TODO Auto-generated method stub
-        System.out.println("*********  greetMeOneWay: " + stringParam0);
-
-    }
-
-}
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+package org.apache.cxf.systest.jms;
+
+import javax.jws.WebService;
+
+import org.apache.cxf.hello_world_jms.HelloWorldPubSubPort;
+
+
+@WebService(serviceName = "JmsDestinationPubSubService", 
+            portName = "JmsDestinationPubSubPort", 
+            endpointInterface = "org.apache.cxf.hello_world_jms.HelloWorldPubSubPort",
+            targetNamespace = "http://cxf.apache.org/hello_world_jms",
+            wsdlLocation = "testutils/jms_test.wsdl")
+
+public class JmsDestPubSubImpl implements HelloWorldPubSubPort {
+
+    public void greetMeOneWay(String stringParam0) {
+        // TODO Auto-generated method stub
+        System.out.println("*********  greetMeOneWay: " + stringParam0);
+
+    }
+
+}

Propchange: cxf/trunk/systests/transport-jms/src/test/java/org/apache/cxf/systest/jms/JmsDestPubSubImpl.java
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: cxf/trunk/systests/transport-jms/src/test/java/org/apache/cxf/systest/jms/JmsDestPubSubImpl.java
------------------------------------------------------------------------------
    svn:keywords = Rev Date

Modified: cxf/trunk/systests/transport-jms/src/test/java/org/apache/cxf/systest/jms/Server.java
URL: http://svn.apache.org/viewvc/cxf/trunk/systests/transport-jms/src/test/java/org/apache/cxf/systest/jms/Server.java?rev=1133913&r1=1133912&r2=1133913&view=diff
==============================================================================
--- cxf/trunk/systests/transport-jms/src/test/java/org/apache/cxf/systest/jms/Server.java (original)
+++ cxf/trunk/systests/transport-jms/src/test/java/org/apache/cxf/systest/jms/Server.java Thu Jun  9 15:08:22 2011
@@ -1,132 +1,132 @@
-/**
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied. See the License for the
- * specific language governing permissions and limitations
- * under the License.
- */
-package org.apache.cxf.systest.jms;
-
-import javax.xml.ws.Binding;
-import javax.xml.ws.Endpoint;
-import javax.xml.ws.soap.SOAPBinding;
-
-import org.apache.cxf.Bus;
-import org.apache.cxf.BusFactory;
-import org.apache.cxf.jaxws.EndpointImpl;
-import org.apache.cxf.jaxws.JaxWsServerFactoryBean;
-import org.apache.cxf.testutil.common.AbstractBusTestServerBase;
-import org.apache.cxf.testutil.common.EmbeddedJMSBrokerLauncher;
-import org.apache.cxf.transport.jms.spec.JMSSpecConstants;
-
-public class Server extends AbstractBusTestServerBase {
-    public static final String PORT = allocatePort(Server.class);
-    
-    protected void run()  {
-        Object implementor = new GreeterImplTwoWayJMS();
-        Object impl2 =  new GreeterImplQueueOneWay();
-        Object impl3  = new GreeterImplTopicOneWay();
-        Object impleDoc = new GreeterImplDoc();
-        Object impl4 = new GreeterByteMessageImpl();
-        Object impl5 =  new SoapService6SoapPort6Impl();
-        Object impl6 = new JmsDestPubSubImpl();
-        Object impl7 =  new SoapService7SoapPort7Impl();
-        Object i1 = new GreeterImplTwoWayJMSAppCorrelationIDNoPrefix();
-        Object i2 = new GreeterImplTwoWayJMSAppCorrelationIDStaticPrefixEng();
-        Object i3 = new GreeterImplTwoWayJMSAppCorrelationIDStaticPrefixSales();
-        Object i4 = new GreeterImplTwoWayJMSRuntimeCorrelationIDDynamicPrefix();
-        Object i5 = new GreeterImplTwoWayJMSRuntimeCorrelationIDStaticPrefixEng();
-        Object i6 = new GreeterImplTwoWayJMSRuntimeCorrelationIDStaticPrefixSales();
-        Object i7 = new GreeterImplTwoWayJMSAppCorrelationIDEng();
-        Object i8 = new GreeterImplTwoWayJMSAppCorrelationIDSales();
-        Object mtom = new JMSMTOMImpl();
-        
-        Bus bus = BusFactory.getDefaultBus();
-        
-        EmbeddedJMSBrokerLauncher.updateWsdlExtensors(bus, "testutils/hello_world_doc_lit.wsdl");
-        EmbeddedJMSBrokerLauncher.updateWsdlExtensors(bus, "testutils/jms_test.wsdl");
-        EmbeddedJMSBrokerLauncher.updateWsdlExtensors(bus, "testutils/jms_test_mtom.wsdl");
-        
-        Endpoint.publish(null, impleDoc);
-        String address = "http://localhost:" + PORT + "/SoapContext/SoapPort";
-        Endpoint.publish(address, implementor);
-        Endpoint.publish("http://testaddr.not.required/", impl2);
-        Endpoint.publish("http://testaddr.not.required.topic/", impl3);
-        Endpoint.publish("http://testaddr.not.required.byte/", impl4);
-        Endpoint.publish("http://testaddr.not.required.jms/", impl5);
-        Endpoint.publish("http://ignore", impl6);
-        Endpoint.publish("", impl7);
-        Endpoint.publish("", i1);
-        Endpoint.publish("", i2);
-        Endpoint.publish("", i3);
-        Endpoint.publish("", i4);
-        Endpoint.publish("", i5);
-        Endpoint.publish("", i6);
-        Endpoint.publish("", i7);
-        Endpoint.publish("", i8);
-        EndpointImpl ep = (EndpointImpl)Endpoint.publish("http://cxf.apache.org/transports/jms", mtom);
-        Binding binding = ep.getBinding();        
-        ((SOAPBinding)binding).setMTOMEnabled(true);  
-        
-        Object spec1 = new GreeterSpecImpl();
-        String address1 = "jms:jndi:dynamicQueues/test.cxf.jmstransport.queue2"
-                         + "?jndiInitialContextFactory"
-                         + "=org.apache.activemq.jndi.ActiveMQInitialContextFactory"
-                         + "&jndiConnectionFactoryName=ConnectionFactory&jndiURL=tcp://localhost:"
-                         + EmbeddedJMSBrokerLauncher.PORT;
-        Endpoint.publish(address1, spec1);
-        
-        Object spec2 = new GreeterSpecWithPortError();
-        String address2 = "jms:jndi:dynamicQueues/test.cxf.jmstransport.queue5"
-            + "?jndiInitialContextFactory"
-            + "=org.apache.activemq.jndi.ActiveMQInitialContextFactory"
-            + "&jndiConnectionFactoryName=ConnectionFactory&jndiURL=tcp://localhost:"
-            + EmbeddedJMSBrokerLauncher.PORT;
-        Endpoint.publish(address2, spec2);
-        
-        initNoWsdlServer();
-    }
-
-
-    /**
-     * 
-     */
-    private void initNoWsdlServer() {
-        String address = "jms:jndi:dynamicQueues/test.cxf.jmstransport.queue3"
-            + "?jndiInitialContextFactory"
-            + "=org.apache.activemq.jndi.ActiveMQInitialContextFactory"
-            + "&jndiConnectionFactoryName=ConnectionFactory&jndiURL=tcp://localhost:"
-            + EmbeddedJMSBrokerLauncher.PORT;
-        Hello implementor = new HelloImpl();
-        JaxWsServerFactoryBean svrFactory = new JaxWsServerFactoryBean();
-        svrFactory.setServiceClass(Hello.class);
-        svrFactory.setAddress(address);
-        svrFactory.setTransportId(JMSSpecConstants.SOAP_JMS_SPECIFICATION_TRANSPORTID);
-        svrFactory.setServiceBean(implementor);
-        svrFactory.create();
-    }
-
-
-    public static void main(String[] args) {
-        try {
-            Server s = new Server();
-            s.start();
-        } catch (Exception ex) {
-            ex.printStackTrace();
-            System.exit(-1);
-        } finally {
-            System.out.println("done!");
-        }
-    }
-}
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+package org.apache.cxf.systest.jms;
+
+import javax.xml.ws.Binding;
+import javax.xml.ws.Endpoint;
+import javax.xml.ws.soap.SOAPBinding;
+
+import org.apache.cxf.Bus;
+import org.apache.cxf.BusFactory;
+import org.apache.cxf.jaxws.EndpointImpl;
+import org.apache.cxf.jaxws.JaxWsServerFactoryBean;
+import org.apache.cxf.testutil.common.AbstractBusTestServerBase;
+import org.apache.cxf.testutil.common.EmbeddedJMSBrokerLauncher;
+import org.apache.cxf.transport.jms.spec.JMSSpecConstants;
+
+public class Server extends AbstractBusTestServerBase {
+    public static final String PORT = allocatePort(Server.class);
+    
+    protected void run()  {
+        Object implementor = new GreeterImplTwoWayJMS();
+        Object impl2 =  new GreeterImplQueueOneWay();
+        Object impl3  = new GreeterImplTopicOneWay();
+        Object impleDoc = new GreeterImplDoc();
+        Object impl4 = new GreeterByteMessageImpl();
+        Object impl5 =  new SoapService6SoapPort6Impl();
+        Object impl6 = new JmsDestPubSubImpl();
+        Object impl7 =  new SoapService7SoapPort7Impl();
+        Object i1 = new GreeterImplTwoWayJMSAppCorrelationIDNoPrefix();
+        Object i2 = new GreeterImplTwoWayJMSAppCorrelationIDStaticPrefixEng();
+        Object i3 = new GreeterImplTwoWayJMSAppCorrelationIDStaticPrefixSales();
+        Object i4 = new GreeterImplTwoWayJMSRuntimeCorrelationIDDynamicPrefix();
+        Object i5 = new GreeterImplTwoWayJMSRuntimeCorrelationIDStaticPrefixEng();
+        Object i6 = new GreeterImplTwoWayJMSRuntimeCorrelationIDStaticPrefixSales();
+        Object i7 = new GreeterImplTwoWayJMSAppCorrelationIDEng();
+        Object i8 = new GreeterImplTwoWayJMSAppCorrelationIDSales();
+        Object mtom = new JMSMTOMImpl();
+        
+        Bus bus = BusFactory.getDefaultBus();
+        
+        EmbeddedJMSBrokerLauncher.updateWsdlExtensors(bus, "testutils/hello_world_doc_lit.wsdl");
+        EmbeddedJMSBrokerLauncher.updateWsdlExtensors(bus, "testutils/jms_test.wsdl");
+        EmbeddedJMSBrokerLauncher.updateWsdlExtensors(bus, "testutils/jms_test_mtom.wsdl");
+        
+        Endpoint.publish(null, impleDoc);
+        String address = "http://localhost:" + PORT + "/SoapContext/SoapPort";
+        Endpoint.publish(address, implementor);
+        Endpoint.publish("http://testaddr.not.required/", impl2);
+        Endpoint.publish("http://testaddr.not.required.topic/", impl3);
+        Endpoint.publish("http://testaddr.not.required.byte/", impl4);
+        Endpoint.publish("http://testaddr.not.required.jms/", impl5);
+        Endpoint.publish("http://ignore", impl6);
+        Endpoint.publish("", impl7);
+        Endpoint.publish("", i1);
+        Endpoint.publish("", i2);
+        Endpoint.publish("", i3);
+        Endpoint.publish("", i4);
+        Endpoint.publish("", i5);
+        Endpoint.publish("", i6);
+        Endpoint.publish("", i7);
+        Endpoint.publish("", i8);
+        EndpointImpl ep = (EndpointImpl)Endpoint.publish("http://cxf.apache.org/transports/jms", mtom);
+        Binding binding = ep.getBinding();        
+        ((SOAPBinding)binding).setMTOMEnabled(true);  
+        
+        Object spec1 = new GreeterSpecImpl();
+        String address1 = "jms:jndi:dynamicQueues/test.cxf.jmstransport.queue2"
+                         + "?jndiInitialContextFactory"
+                         + "=org.apache.activemq.jndi.ActiveMQInitialContextFactory"
+                         + "&jndiConnectionFactoryName=ConnectionFactory&jndiURL=tcp://localhost:"
+                         + EmbeddedJMSBrokerLauncher.PORT;
+        Endpoint.publish(address1, spec1);
+        
+        Object spec2 = new GreeterSpecWithPortError();
+        String address2 = "jms:jndi:dynamicQueues/test.cxf.jmstransport.queue5"
+            + "?jndiInitialContextFactory"
+            + "=org.apache.activemq.jndi.ActiveMQInitialContextFactory"
+            + "&jndiConnectionFactoryName=ConnectionFactory&jndiURL=tcp://localhost:"
+            + EmbeddedJMSBrokerLauncher.PORT;
+        Endpoint.publish(address2, spec2);
+        
+        initNoWsdlServer();
+    }
+
+
+    /**
+     * 
+     */
+    private void initNoWsdlServer() {
+        String address = "jms:jndi:dynamicQueues/test.cxf.jmstransport.queue3"
+            + "?jndiInitialContextFactory"
+            + "=org.apache.activemq.jndi.ActiveMQInitialContextFactory"
+            + "&jndiConnectionFactoryName=ConnectionFactory&jndiURL=tcp://localhost:"
+            + EmbeddedJMSBrokerLauncher.PORT;
+        Hello implementor = new HelloImpl();
+        JaxWsServerFactoryBean svrFactory = new JaxWsServerFactoryBean();
+        svrFactory.setServiceClass(Hello.class);
+        svrFactory.setAddress(address);
+        svrFactory.setTransportId(JMSSpecConstants.SOAP_JMS_SPECIFICATION_TRANSPORTID);
+        svrFactory.setServiceBean(implementor);
+        svrFactory.create();
+    }
+
+
+    public static void main(String[] args) {
+        try {
+            Server s = new Server();
+            s.start();
+        } catch (Exception ex) {
+            ex.printStackTrace();
+            System.exit(-1);
+        } finally {
+            System.out.println("done!");
+        }
+    }
+}

Propchange: cxf/trunk/systests/transport-jms/src/test/java/org/apache/cxf/systest/jms/Server.java
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: cxf/trunk/systests/transport-jms/src/test/java/org/apache/cxf/systest/jms/Server.java
------------------------------------------------------------------------------
    svn:keywords = Rev Date

Modified: cxf/trunk/systests/transport-jms/src/test/java/org/apache/cxf/systest/jms/SoapService6SoapPort6Impl.java
URL: http://svn.apache.org/viewvc/cxf/trunk/systests/transport-jms/src/test/java/org/apache/cxf/systest/jms/SoapService6SoapPort6Impl.java?rev=1133913&r1=1133912&r2=1133913&view=diff
==============================================================================
--- cxf/trunk/systests/transport-jms/src/test/java/org/apache/cxf/systest/jms/SoapService6SoapPort6Impl.java (original)
+++ cxf/trunk/systests/transport-jms/src/test/java/org/apache/cxf/systest/jms/SoapService6SoapPort6Impl.java Thu Jun  9 15:08:22 2011
@@ -1,30 +1,30 @@
-/**
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied. See the License for the
- * specific language governing permissions and limitations
- * under the License.
- */
-package org.apache.cxf.systest.jms;
-
-import javax.jws.WebService;
-
-@WebService(serviceName = "SOAPService6", 
-            portName = "SoapPort6", 
-            endpointInterface = "org.apache.hello_world_doc_lit.Greeter",
-            targetNamespace = "http://apache.org/hello_world_doc_lit",
-            wsdlLocation = "testutils/hello_world_doc_lit.wsdl")
-public class SoapService6SoapPort6Impl extends GreeterImplDocBase {
-
-}
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+package org.apache.cxf.systest.jms;
+
+import javax.jws.WebService;
+
+@WebService(serviceName = "SOAPService6", 
+            portName = "SoapPort6", 
+            endpointInterface = "org.apache.hello_world_doc_lit.Greeter",
+            targetNamespace = "http://apache.org/hello_world_doc_lit",
+            wsdlLocation = "testutils/hello_world_doc_lit.wsdl")
+public class SoapService6SoapPort6Impl extends GreeterImplDocBase {
+
+}

Propchange: cxf/trunk/systests/transport-jms/src/test/java/org/apache/cxf/systest/jms/SoapService6SoapPort6Impl.java
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: cxf/trunk/systests/transport-jms/src/test/java/org/apache/cxf/systest/jms/SoapService6SoapPort6Impl.java
------------------------------------------------------------------------------
    svn:keywords = Rev Date

Modified: cxf/trunk/systests/transport-jms/src/test/java/org/apache/cxf/systest/jms/SoapService7SoapPort7Impl.java
URL: http://svn.apache.org/viewvc/cxf/trunk/systests/transport-jms/src/test/java/org/apache/cxf/systest/jms/SoapService7SoapPort7Impl.java?rev=1133913&r1=1133912&r2=1133913&view=diff
==============================================================================
--- cxf/trunk/systests/transport-jms/src/test/java/org/apache/cxf/systest/jms/SoapService7SoapPort7Impl.java (original)
+++ cxf/trunk/systests/transport-jms/src/test/java/org/apache/cxf/systest/jms/SoapService7SoapPort7Impl.java Thu Jun  9 15:08:22 2011
@@ -1,30 +1,30 @@
-/**
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied. See the License for the
- * specific language governing permissions and limitations
- * under the License.
- */
-package org.apache.cxf.systest.jms;
-
-import javax.jws.WebService;
-
-@WebService(serviceName = "SOAPService7", 
-            portName = "SoapPort7", 
-            endpointInterface = "org.apache.hello_world_doc_lit.Greeter",
-            targetNamespace = "http://apache.org/hello_world_doc_lit",
-            wsdlLocation = "testutils/hello_world_doc_lit.wsdl")
-public class SoapService7SoapPort7Impl extends GreeterImplDocBase {
-
-}
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+package org.apache.cxf.systest.jms;
+
+import javax.jws.WebService;
+
+@WebService(serviceName = "SOAPService7", 
+            portName = "SoapPort7", 
+            endpointInterface = "org.apache.hello_world_doc_lit.Greeter",
+            targetNamespace = "http://apache.org/hello_world_doc_lit",
+            wsdlLocation = "testutils/hello_world_doc_lit.wsdl")
+public class SoapService7SoapPort7Impl extends GreeterImplDocBase {
+
+}

Propchange: cxf/trunk/systests/transport-jms/src/test/java/org/apache/cxf/systest/jms/SoapService7SoapPort7Impl.java
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: cxf/trunk/systests/transport-jms/src/test/java/org/apache/cxf/systest/jms/SoapService7SoapPort7Impl.java
------------------------------------------------------------------------------
    svn:keywords = Rev Date

Modified: cxf/trunk/systests/transport-jms/src/test/java/org/apache/cxf/systest/jms/TwoWayJMSImplBase.java
URL: http://svn.apache.org/viewvc/cxf/trunk/systests/transport-jms/src/test/java/org/apache/cxf/systest/jms/TwoWayJMSImplBase.java?rev=1133913&r1=1133912&r2=1133913&view=diff
==============================================================================
--- cxf/trunk/systests/transport-jms/src/test/java/org/apache/cxf/systest/jms/TwoWayJMSImplBase.java (original)
+++ cxf/trunk/systests/transport-jms/src/test/java/org/apache/cxf/systest/jms/TwoWayJMSImplBase.java Thu Jun  9 15:08:22 2011
@@ -1,132 +1,132 @@
-/**
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied. See the License for the
- * specific language governing permissions and limitations
- * under the License.
- */
-package org.apache.cxf.systest.jms;
-
-import java.util.concurrent.Future;
-
-import javax.annotation.Resource;
-import javax.xml.ws.AsyncHandler;
-import javax.xml.ws.Response;
-import javax.xml.ws.WebServiceContext;
-import javax.xml.ws.handler.MessageContext;
-
-import org.apache.cxf.hello_world_jms.BadRecordLitFault;
-import org.apache.cxf.hello_world_jms.HelloWorldPortType;
-import org.apache.cxf.hello_world_jms.NoSuchCodeLitFault;
-import org.apache.cxf.hello_world_jms.types.BadRecordLit;
-import org.apache.cxf.hello_world_jms.types.ErrorCode;
-import org.apache.cxf.hello_world_jms.types.NoSuchCodeLit;
-import org.apache.cxf.hello_world_jms.types.TestRpcLitFaultResponse;
-import org.apache.cxf.transport.jms.JMSConstants;
-import org.apache.cxf.transport.jms.JMSMessageHeadersType;
-import org.apache.cxf.transport.jms.JMSPropertyType;
-
-public class TwoWayJMSImplBase implements HelloWorldPortType {
-
-    @Resource
-    protected WebServiceContext wsContext;
-    public String greetMe(String me) {
-        if (me.startsWith("PauseForTwoSecs")) {
-            try {
-                Thread.sleep(2000);
-            } catch (InterruptedException e) {
-                //ignore
-            }
-            me = me.substring("PauseForTwoSecs".length()).trim();
-        }
-        
-        MessageContext mc = wsContext.getMessageContext();
-        JMSMessageHeadersType headers =
-            (JMSMessageHeadersType) mc.get(JMSConstants.JMS_SERVER_REQUEST_HEADERS);
-        System.out.println("get the message headers JMSCorrelationID: " + headers.getJMSCorrelationID());
-        System.out.println("Reached here :" + me);
-        
-        // set reply header custom property
-        JMSPropertyType testProperty = new JMSPropertyType();
-        testProperty.setName("Test_Prop");
-        testProperty.setValue("some return value "  + me);
-        
-        System.out.println("found property in request headers at index: " 
-                           + headers.getProperty().indexOf(testProperty));
-        
-        JMSMessageHeadersType responseHeaders =
-            (JMSMessageHeadersType) mc.get(JMSConstants.JMS_SERVER_RESPONSE_HEADERS);
-        responseHeaders.getProperty().add(testProperty);
-        
-        return "Hello " + me;
-    }
-
-    public String sayHi() {        
-        return "Bonjour";
-    }
-    
-    public void greetMeOneWay(String requestType) {
-        System.out.println("*********  greetMeOneWay: " + requestType);
-    }
-    
-    public TestRpcLitFaultResponse testRpcLitFault(String faultType) 
-        throws BadRecordLitFault, NoSuchCodeLitFault {
-        BadRecordLit badRecord = new BadRecordLit();
-        badRecord.setReason("BadRecordLitFault");
-        if (faultType.equals(BadRecordLitFault.class.getSimpleName())) {
-            throw new BadRecordLitFault("TestBadRecordLit", badRecord);
-        }
-        if (faultType.equals(NoSuchCodeLitFault.class.getSimpleName())) {
-            ErrorCode ec = new ErrorCode();
-            ec.setMajor((short)1);
-            ec.setMinor((short)1);
-            NoSuchCodeLit nscl = new NoSuchCodeLit();
-            nscl.setCode(ec);
-            throw new NoSuchCodeLitFault("TestNoSuchCodeLit", nscl);
-        }
-        
-        return new TestRpcLitFaultResponse();
-    }
-
-    public Response<String> greetMeAsync(String stringParam0) {
-        // TODO Auto-generated method stub
-        return null;
-    }
-
-    public Future<?> greetMeAsync(String stringParam0, AsyncHandler<String> asyncHandler) {
-        // TODO Auto-generated method stub
-        return null;
-    }
-
-    public Response<String> sayHiAsync() {
-        // TODO Auto-generated method stub
-        return null;
-    }
-
-    public Future<?> sayHiAsync(AsyncHandler<String> asyncHandler) {
-        // TODO Auto-generated method stub
-        return null;
-    }
-
-    public Response<TestRpcLitFaultResponse> testRpcLitFaultAsync(String in) {
-        // TODO Auto-generated method stub
-        return null;
-    }
-
-    public Future<?> testRpcLitFaultAsync(String in, AsyncHandler<TestRpcLitFaultResponse> asyncHandler) {
-        // TODO Auto-generated method stub
-        return null;
-    }
-
-}
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+package org.apache.cxf.systest.jms;
+
+import java.util.concurrent.Future;
+
+import javax.annotation.Resource;
+import javax.xml.ws.AsyncHandler;
+import javax.xml.ws.Response;
+import javax.xml.ws.WebServiceContext;
+import javax.xml.ws.handler.MessageContext;
+
+import org.apache.cxf.hello_world_jms.BadRecordLitFault;
+import org.apache.cxf.hello_world_jms.HelloWorldPortType;
+import org.apache.cxf.hello_world_jms.NoSuchCodeLitFault;
+import org.apache.cxf.hello_world_jms.types.BadRecordLit;
+import org.apache.cxf.hello_world_jms.types.ErrorCode;
+import org.apache.cxf.hello_world_jms.types.NoSuchCodeLit;
+import org.apache.cxf.hello_world_jms.types.TestRpcLitFaultResponse;
+import org.apache.cxf.transport.jms.JMSConstants;
+import org.apache.cxf.transport.jms.JMSMessageHeadersType;
+import org.apache.cxf.transport.jms.JMSPropertyType;
+
+public class TwoWayJMSImplBase implements HelloWorldPortType {
+
+    @Resource
+    protected WebServiceContext wsContext;
+    public String greetMe(String me) {
+        if (me.startsWith("PauseForTwoSecs")) {
+            try {
+                Thread.sleep(2000);
+            } catch (InterruptedException e) {
+                //ignore
+            }
+            me = me.substring("PauseForTwoSecs".length()).trim();
+        }
+        
+        MessageContext mc = wsContext.getMessageContext();
+        JMSMessageHeadersType headers =
+            (JMSMessageHeadersType) mc.get(JMSConstants.JMS_SERVER_REQUEST_HEADERS);
+        System.out.println("get the message headers JMSCorrelationID: " + headers.getJMSCorrelationID());
+        System.out.println("Reached here :" + me);
+        
+        // set reply header custom property
+        JMSPropertyType testProperty = new JMSPropertyType();
+        testProperty.setName("Test_Prop");
+        testProperty.setValue("some return value "  + me);
+        
+        System.out.println("found property in request headers at index: " 
+                           + headers.getProperty().indexOf(testProperty));
+        
+        JMSMessageHeadersType responseHeaders =
+            (JMSMessageHeadersType) mc.get(JMSConstants.JMS_SERVER_RESPONSE_HEADERS);
+        responseHeaders.getProperty().add(testProperty);
+        
+        return "Hello " + me;
+    }
+
+    public String sayHi() {        
+        return "Bonjour";
+    }
+    
+    public void greetMeOneWay(String requestType) {
+        System.out.println("*********  greetMeOneWay: " + requestType);
+    }
+    
+    public TestRpcLitFaultResponse testRpcLitFault(String faultType) 
+        throws BadRecordLitFault, NoSuchCodeLitFault {
+        BadRecordLit badRecord = new BadRecordLit();
+        badRecord.setReason("BadRecordLitFault");
+        if (faultType.equals(BadRecordLitFault.class.getSimpleName())) {
+            throw new BadRecordLitFault("TestBadRecordLit", badRecord);
+        }
+        if (faultType.equals(NoSuchCodeLitFault.class.getSimpleName())) {
+            ErrorCode ec = new ErrorCode();
+            ec.setMajor((short)1);
+            ec.setMinor((short)1);
+            NoSuchCodeLit nscl = new NoSuchCodeLit();
+            nscl.setCode(ec);
+            throw new NoSuchCodeLitFault("TestNoSuchCodeLit", nscl);
+        }
+        
+        return new TestRpcLitFaultResponse();
+    }
+
+    public Response<String> greetMeAsync(String stringParam0) {
+        // TODO Auto-generated method stub
+        return null;
+    }
+
+    public Future<?> greetMeAsync(String stringParam0, AsyncHandler<String> asyncHandler) {
+        // TODO Auto-generated method stub
+        return null;
+    }
+
+    public Response<String> sayHiAsync() {
+        // TODO Auto-generated method stub
+        return null;
+    }
+
+    public Future<?> sayHiAsync(AsyncHandler<String> asyncHandler) {
+        // TODO Auto-generated method stub
+        return null;
+    }
+
+    public Response<TestRpcLitFaultResponse> testRpcLitFaultAsync(String in) {
+        // TODO Auto-generated method stub
+        return null;
+    }
+
+    public Future<?> testRpcLitFaultAsync(String in, AsyncHandler<TestRpcLitFaultResponse> asyncHandler) {
+        // TODO Auto-generated method stub
+        return null;
+    }
+
+}

Propchange: cxf/trunk/systests/transport-jms/src/test/java/org/apache/cxf/systest/jms/TwoWayJMSImplBase.java
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: cxf/trunk/systests/transport-jms/src/test/java/org/apache/cxf/systest/jms/TwoWayJMSImplBase.java
------------------------------------------------------------------------------
    svn:keywords = Rev Date

Modified: cxf/trunk/systests/transport-jms/src/test/java/org/apache/cxf/systest/jms/continuations/GreeterImplWithContinuationsJMS.java
URL: http://svn.apache.org/viewvc/cxf/trunk/systests/transport-jms/src/test/java/org/apache/cxf/systest/jms/continuations/GreeterImplWithContinuationsJMS.java?rev=1133913&r1=1133912&r2=1133913&view=diff
==============================================================================
--- cxf/trunk/systests/transport-jms/src/test/java/org/apache/cxf/systest/jms/continuations/GreeterImplWithContinuationsJMS.java (original)
+++ cxf/trunk/systests/transport-jms/src/test/java/org/apache/cxf/systest/jms/continuations/GreeterImplWithContinuationsJMS.java Thu Jun  9 15:08:22 2011
@@ -1,96 +1,96 @@
-/**
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied. See the License for the
- * specific language governing permissions and limitations
- * under the License.
- */
-package org.apache.cxf.systest.jms.continuations;
-
-import javax.annotation.Resource;
-import javax.jws.WebService;
-import javax.xml.ws.WebServiceContext;
-
-import org.apache.cxf.continuations.Continuation;
-import org.apache.cxf.continuations.ContinuationProvider;
-
-
-
-@WebService(serviceName = "HelloWorldService", 
-            portName = "HelloWorldPort",
-            endpointInterface = "org.apache.cxf.hello_world_jms.HelloWorldPortType",
-            targetNamespace = "http://cxf.apache.org/hello_world_jms",
-            wsdlLocation = "testutils/jms_test.wsdl")
-public class GreeterImplWithContinuationsJMS {    
-    
-    @Resource
-    protected WebServiceContext context;
-    private volatile boolean suspended; 
-    
-    public void greetMeOneWay(String name) {
-        throw new UnsupportedOperationException();
-    }
-    
-    public String sayHi() {
-        throw new UnsupportedOperationException();
-    }
-    
-    public void testRpcLitFault(String s) {
-        throw new UnsupportedOperationException();
-    }
-    
-    public String greetMe(String name) {
-        
-        Continuation continuation = getContinuation(name);
-        if (continuation == null) {
-            throw new RuntimeException("Failed to get continuation");
-        }
-        synchronized (continuation) {
-            if (continuation.isNew()) {
-                if (suspended) {
-                    throw new RuntimeException("Was already suspended");
-                }
-                Object userObject = "Fred".equals(name) ? "Ruby" : null;
-                continuation.setObject(userObject);
-                suspended = true;
-                continuation.suspend(2000);
-            } else {
-                if (!suspended) {
-                    throw new RuntimeException("Was not suspended yet");
-                }
-                if (continuation.isResumed()) {
-                    throw new RuntimeException("It must be a timeout");
-                }
-                StringBuilder sb = new StringBuilder();
-                sb.append(name);
-                
-                Object userObject = continuation.getObject();
-                if (userObject != null) {
-                    sb.append(' ').append(userObject.toString());
-                }
-                System.out.println("Saying hi to " + sb.toString());
-                return "Hi " + sb.toString();
-            }
-        }
-        // unreachable
-        return null;        
-    }
-    
-    private Continuation getContinuation(String name) {
-        
-        ContinuationProvider provider = 
-            (ContinuationProvider)context.getMessageContext().get(ContinuationProvider.class.getName());
-        return provider.getContinuation();
-    }
-}
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+package org.apache.cxf.systest.jms.continuations;
+
+import javax.annotation.Resource;
+import javax.jws.WebService;
+import javax.xml.ws.WebServiceContext;
+
+import org.apache.cxf.continuations.Continuation;
+import org.apache.cxf.continuations.ContinuationProvider;
+
+
+
+@WebService(serviceName = "HelloWorldService", 
+            portName = "HelloWorldPort",
+            endpointInterface = "org.apache.cxf.hello_world_jms.HelloWorldPortType",
+            targetNamespace = "http://cxf.apache.org/hello_world_jms",
+            wsdlLocation = "testutils/jms_test.wsdl")
+public class GreeterImplWithContinuationsJMS {    
+    
+    @Resource
+    protected WebServiceContext context;
+    private volatile boolean suspended; 
+    
+    public void greetMeOneWay(String name) {
+        throw new UnsupportedOperationException();
+    }
+    
+    public String sayHi() {
+        throw new UnsupportedOperationException();
+    }
+    
+    public void testRpcLitFault(String s) {
+        throw new UnsupportedOperationException();
+    }
+    
+    public String greetMe(String name) {
+        
+        Continuation continuation = getContinuation(name);
+        if (continuation == null) {
+            throw new RuntimeException("Failed to get continuation");
+        }
+        synchronized (continuation) {
+            if (continuation.isNew()) {
+                if (suspended) {
+                    throw new RuntimeException("Was already suspended");
+                }
+                Object userObject = "Fred".equals(name) ? "Ruby" : null;
+                continuation.setObject(userObject);
+                suspended = true;
+                continuation.suspend(2000);
+            } else {
+                if (!suspended) {
+                    throw new RuntimeException("Was not suspended yet");
+                }
+                if (continuation.isResumed()) {
+                    throw new RuntimeException("It must be a timeout");
+                }
+                StringBuilder sb = new StringBuilder();
+                sb.append(name);
+                
+                Object userObject = continuation.getObject();
+                if (userObject != null) {
+                    sb.append(' ').append(userObject.toString());
+                }
+                System.out.println("Saying hi to " + sb.toString());
+                return "Hi " + sb.toString();
+            }
+        }
+        // unreachable
+        return null;        
+    }
+    
+    private Continuation getContinuation(String name) {
+        
+        ContinuationProvider provider = 
+            (ContinuationProvider)context.getMessageContext().get(ContinuationProvider.class.getName());
+        return provider.getContinuation();
+    }
+}

Propchange: cxf/trunk/systests/transport-jms/src/test/java/org/apache/cxf/systest/jms/continuations/GreeterImplWithContinuationsJMS.java
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: cxf/trunk/systests/transport-jms/src/test/java/org/apache/cxf/systest/jms/continuations/GreeterImplWithContinuationsJMS.java
------------------------------------------------------------------------------
    svn:keywords = Rev Date

Modified: cxf/trunk/systests/transport-jms/src/test/java/org/apache/cxf/systest/jms/continuations/HWSoapMessageDocProvider.java
URL: http://svn.apache.org/viewvc/cxf/trunk/systests/transport-jms/src/test/java/org/apache/cxf/systest/jms/continuations/HWSoapMessageDocProvider.java?rev=1133913&r1=1133912&r2=1133913&view=diff
==============================================================================
--- cxf/trunk/systests/transport-jms/src/test/java/org/apache/cxf/systest/jms/continuations/HWSoapMessageDocProvider.java (original)
+++ cxf/trunk/systests/transport-jms/src/test/java/org/apache/cxf/systest/jms/continuations/HWSoapMessageDocProvider.java Thu Jun  9 15:08:22 2011
@@ -1,138 +1,138 @@
-/**
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied. See the License for the
- * specific language governing permissions and limitations
- * under the License.
- */
-package org.apache.cxf.systest.jms.continuations;
-
-import java.io.InputStream;
-
-import javax.annotation.Resource;
-import javax.xml.namespace.QName;
-import javax.xml.soap.MessageFactory;
-import javax.xml.soap.SOAPBody;
-import javax.xml.soap.SOAPMessage;
-import javax.xml.ws.Provider;
-import javax.xml.ws.Service;
-import javax.xml.ws.ServiceMode;
-import javax.xml.ws.WebServiceContext;
-import javax.xml.ws.WebServiceProvider;
-import javax.xml.ws.handler.MessageContext;
-import javax.xml.ws.soap.SOAPFaultException;
-
-import org.w3c.dom.Element;
-import org.w3c.dom.Node;
-
-import org.apache.cxf.continuations.Continuation;
-import org.apache.cxf.continuations.ContinuationProvider;
-import org.apache.cxf.helpers.DOMUtils;
-
-
-
-@WebServiceProvider(serviceName = "HelloWorldService", 
-            portName = "HelloWorldPort",
-            targetNamespace = "http://cxf.apache.org/hello_world_jms",
-            wsdlLocation = "/org/apache/cxf/systest/jms/continuations/jms_test.wsdl")
-@ServiceMode(value = Service.Mode.MESSAGE)
-public class HWSoapMessageDocProvider implements Provider<SOAPMessage> {
-
-    private static QName sayHi = new QName("http://apache.org/hello_world_soap_http", "sayHi");
-    private static QName greetMe = new QName("http://apache.org/hello_world_soap_http", "greetMe");
-    
-    @Resource 
-    WebServiceContext ctx;
-    
-    private SOAPMessage sayHiResponse;
-    private SOAPMessage greetMeResponse;
-    
-    public HWSoapMessageDocProvider() {
-       
-        try {
-            MessageFactory factory = MessageFactory.newInstance();            
-            InputStream is = getClass().getResourceAsStream("resources/GreetMeDocLiteralResp.xml");
-            greetMeResponse =  factory.createMessage(null, is);
-            is.close();
-        } catch (Exception ex) {
-            ex.printStackTrace();
-        }
-    }
-    
-    public SOAPMessage invoke(SOAPMessage request) {
-        try {
-            final MessageContext messageContext = ctx.getMessageContext();
-
-            ContinuationProvider contProvider = 
-                (ContinuationProvider) messageContext.get(ContinuationProvider.class.getName());
-            final Continuation continuation = contProvider.getContinuation();
-            
-            if (continuation.isNew()) {
-                continuation.suspend(5000);
-                new Thread(new Runnable() {
-                    public void run() {
-                        try {
-                            continuation.resume();
-                        } catch (Exception e) {
-                            e.printStackTrace();
-                        }
-                    }
-                }).start();
-                return null;
-            } else if (!continuation.isResumed()) {
-                continuation.reset();
-                throw new RuntimeException("time out");
-            } else {
-                return resumeMessage(request);
-            }
-        } catch (SOAPFaultException e) {
-            throw e;
-        } 
-        
-    }
-    
-    public SOAPMessage resumeMessage(SOAPMessage request) {
-        if (IncomingMessageCounterInterceptor.getMessageCount() != 1) {
-            throw new RuntimeException("IncomingMessageCounterInterceptor get invoked twice");
-        }
-        QName qn = (QName)ctx.getMessageContext().get(MessageContext.WSDL_OPERATION);
-        if (qn == null) {
-            throw new RuntimeException("No Operation Name");
-        }
-        
-        SOAPMessage response = null;        
-        try {
-            SOAPBody body = request.getSOAPBody();
-            Node n = body.getFirstChild();
-
-            while (n.getNodeType() != Node.ELEMENT_NODE) {
-                n = n.getNextSibling();
-            }
-            if (n.getLocalName().equals(sayHi.getLocalPart())) {
-                response = sayHiResponse;
-            } else if (n.getLocalName().equals(greetMe.getLocalPart())) {
-                Element el = DOMUtils.getFirstElement(n);
-                String v = DOMUtils.getContent(el);
-                if (v.contains("Return sayHi")) {
-                    response = sayHiResponse;
-                } else {
-                    response = greetMeResponse;
-                }
-            }
-        } catch (Exception ex) {
-            ex.printStackTrace();
-        }
-        return response;
-    }
-}
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+package org.apache.cxf.systest.jms.continuations;
+
+import java.io.InputStream;
+
+import javax.annotation.Resource;
+import javax.xml.namespace.QName;
+import javax.xml.soap.MessageFactory;
+import javax.xml.soap.SOAPBody;
+import javax.xml.soap.SOAPMessage;
+import javax.xml.ws.Provider;
+import javax.xml.ws.Service;
+import javax.xml.ws.ServiceMode;
+import javax.xml.ws.WebServiceContext;
+import javax.xml.ws.WebServiceProvider;
+import javax.xml.ws.handler.MessageContext;
+import javax.xml.ws.soap.SOAPFaultException;
+
+import org.w3c.dom.Element;
+import org.w3c.dom.Node;
+
+import org.apache.cxf.continuations.Continuation;
+import org.apache.cxf.continuations.ContinuationProvider;
+import org.apache.cxf.helpers.DOMUtils;
+
+
+
+@WebServiceProvider(serviceName = "HelloWorldService", 
+            portName = "HelloWorldPort",
+            targetNamespace = "http://cxf.apache.org/hello_world_jms",
+            wsdlLocation = "/org/apache/cxf/systest/jms/continuations/jms_test.wsdl")
+@ServiceMode(value = Service.Mode.MESSAGE)
+public class HWSoapMessageDocProvider implements Provider<SOAPMessage> {
+
+    private static QName sayHi = new QName("http://apache.org/hello_world_soap_http", "sayHi");
+    private static QName greetMe = new QName("http://apache.org/hello_world_soap_http", "greetMe");
+    
+    @Resource 
+    WebServiceContext ctx;
+    
+    private SOAPMessage sayHiResponse;
+    private SOAPMessage greetMeResponse;
+    
+    public HWSoapMessageDocProvider() {
+       
+        try {
+            MessageFactory factory = MessageFactory.newInstance();            
+            InputStream is = getClass().getResourceAsStream("resources/GreetMeDocLiteralResp.xml");
+            greetMeResponse =  factory.createMessage(null, is);
+            is.close();
+        } catch (Exception ex) {
+            ex.printStackTrace();
+        }
+    }
+    
+    public SOAPMessage invoke(SOAPMessage request) {
+        try {
+            final MessageContext messageContext = ctx.getMessageContext();
+
+            ContinuationProvider contProvider = 
+                (ContinuationProvider) messageContext.get(ContinuationProvider.class.getName());
+            final Continuation continuation = contProvider.getContinuation();
+            
+            if (continuation.isNew()) {
+                continuation.suspend(5000);
+                new Thread(new Runnable() {
+                    public void run() {
+                        try {
+                            continuation.resume();
+                        } catch (Exception e) {
+                            e.printStackTrace();
+                        }
+                    }
+                }).start();
+                return null;
+            } else if (!continuation.isResumed()) {
+                continuation.reset();
+                throw new RuntimeException("time out");
+            } else {
+                return resumeMessage(request);
+            }
+        } catch (SOAPFaultException e) {
+            throw e;
+        } 
+        
+    }
+    
+    public SOAPMessage resumeMessage(SOAPMessage request) {
+        if (IncomingMessageCounterInterceptor.getMessageCount() != 1) {
+            throw new RuntimeException("IncomingMessageCounterInterceptor get invoked twice");
+        }
+        QName qn = (QName)ctx.getMessageContext().get(MessageContext.WSDL_OPERATION);
+        if (qn == null) {
+            throw new RuntimeException("No Operation Name");
+        }
+        
+        SOAPMessage response = null;        
+        try {
+            SOAPBody body = request.getSOAPBody();
+            Node n = body.getFirstChild();
+
+            while (n.getNodeType() != Node.ELEMENT_NODE) {
+                n = n.getNextSibling();
+            }
+            if (n.getLocalName().equals(sayHi.getLocalPart())) {
+                response = sayHiResponse;
+            } else if (n.getLocalName().equals(greetMe.getLocalPart())) {
+                Element el = DOMUtils.getFirstElement(n);
+                String v = DOMUtils.getContent(el);
+                if (v.contains("Return sayHi")) {
+                    response = sayHiResponse;
+                } else {
+                    response = greetMeResponse;
+                }
+            }
+        } catch (Exception ex) {
+            ex.printStackTrace();
+        }
+        return response;
+    }
+}

Propchange: cxf/trunk/systests/transport-jms/src/test/java/org/apache/cxf/systest/jms/continuations/HWSoapMessageDocProvider.java
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: cxf/trunk/systests/transport-jms/src/test/java/org/apache/cxf/systest/jms/continuations/HWSoapMessageDocProvider.java
------------------------------------------------------------------------------
    svn:keywords = Rev Date

Modified: cxf/trunk/systests/transport-jms/src/test/java/org/apache/cxf/systest/jms/continuations/HelloContinuation.java
URL: http://svn.apache.org/viewvc/cxf/trunk/systests/transport-jms/src/test/java/org/apache/cxf/systest/jms/continuations/HelloContinuation.java?rev=1133913&r1=1133912&r2=1133913&view=diff
==============================================================================
--- cxf/trunk/systests/transport-jms/src/test/java/org/apache/cxf/systest/jms/continuations/HelloContinuation.java (original)
+++ cxf/trunk/systests/transport-jms/src/test/java/org/apache/cxf/systest/jms/continuations/HelloContinuation.java Thu Jun  9 15:08:22 2011
@@ -1,36 +1,36 @@
-/**
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied. See the License for the
- * specific language governing permissions and limitations
- * under the License.
- */
-package org.apache.cxf.systest.jms.continuations;
-
-import javax.jws.WebMethod;
-import javax.jws.WebService;
-import javax.jws.soap.SOAPBinding;
-
-@SOAPBinding(style = SOAPBinding.Style.RPC, use = SOAPBinding.Use.LITERAL)
-@WebService(name = "HelloContinuation", targetNamespace = "http://cxf.apache.org/systest/jaxws")
-public interface HelloContinuation {
-    @WebMethod(operationName = "sayHi", exclude = false)
-    String sayHi(String firstName, String secondName);
-    
-    @WebMethod(operationName = "isRequestSuspended", exclude = false)
-    boolean isRequestSuspended(String name);
-    
-    @WebMethod(operationName = "resumeRequest", exclude = false)
-    void resumeRequest(String name);
-}
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+package org.apache.cxf.systest.jms.continuations;
+
+import javax.jws.WebMethod;
+import javax.jws.WebService;
+import javax.jws.soap.SOAPBinding;
+
+@SOAPBinding(style = SOAPBinding.Style.RPC, use = SOAPBinding.Use.LITERAL)
+@WebService(name = "HelloContinuation", targetNamespace = "http://cxf.apache.org/systest/jaxws")
+public interface HelloContinuation {
+    @WebMethod(operationName = "sayHi", exclude = false)
+    String sayHi(String firstName, String secondName);
+    
+    @WebMethod(operationName = "isRequestSuspended", exclude = false)
+    boolean isRequestSuspended(String name);
+    
+    @WebMethod(operationName = "resumeRequest", exclude = false)
+    void resumeRequest(String name);
+}

Propchange: cxf/trunk/systests/transport-jms/src/test/java/org/apache/cxf/systest/jms/continuations/HelloContinuation.java
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: cxf/trunk/systests/transport-jms/src/test/java/org/apache/cxf/systest/jms/continuations/HelloContinuation.java
------------------------------------------------------------------------------
    svn:keywords = Rev Date

Modified: cxf/trunk/systests/transport-jms/src/test/java/org/apache/cxf/systest/jms/continuations/HelloContinuationService.java
URL: http://svn.apache.org/viewvc/cxf/trunk/systests/transport-jms/src/test/java/org/apache/cxf/systest/jms/continuations/HelloContinuationService.java?rev=1133913&r1=1133912&r2=1133913&view=diff
==============================================================================
--- cxf/trunk/systests/transport-jms/src/test/java/org/apache/cxf/systest/jms/continuations/HelloContinuationService.java (original)
+++ cxf/trunk/systests/transport-jms/src/test/java/org/apache/cxf/systest/jms/continuations/HelloContinuationService.java Thu Jun  9 15:08:22 2011
@@ -1,49 +1,49 @@
-/**
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied. See the License for the
- * specific language governing permissions and limitations
- * under the License.
- */
-package org.apache.cxf.systest.jms.continuations;
-
-import java.net.URL;
-
-import javax.xml.namespace.QName;
-import javax.xml.ws.Service;
-import javax.xml.ws.WebEndpoint;
-import javax.xml.ws.WebServiceClient;
-
-/**
- * 
- */
-
-@WebServiceClient(name = "HelloService", 
-                  targetNamespace = "http://cxf.apache.org/systest/jaxws", 
-                  wsdlLocation = "testutils/hello.wsdl")
-public class HelloContinuationService extends Service {
-    static final QName SERVICE = 
-        new QName("http://cxf.apache.org/systest/jaxws", "HelloContinuationService");
-    static final QName HELLO_PORT = 
-        new QName("http://cxf.apache.org/systest/jaxws", "HelloContinuationPort");
-    public HelloContinuationService(URL wsdlLocation, QName serviceName) {
-        super(wsdlLocation, serviceName);
-    }
-
-    @WebEndpoint(name = "HelloContinuationPort")
-    public HelloContinuation getHelloContinuationPort() {
-        return (HelloContinuation)super.getPort(HELLO_PORT, HelloContinuation.class);
-    }
-
-}
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+package org.apache.cxf.systest.jms.continuations;
+
+import java.net.URL;
+
+import javax.xml.namespace.QName;
+import javax.xml.ws.Service;
+import javax.xml.ws.WebEndpoint;
+import javax.xml.ws.WebServiceClient;
+
+/**
+ * 
+ */
+
+@WebServiceClient(name = "HelloService", 
+                  targetNamespace = "http://cxf.apache.org/systest/jaxws", 
+                  wsdlLocation = "testutils/hello.wsdl")
+public class HelloContinuationService extends Service {
+    static final QName SERVICE = 
+        new QName("http://cxf.apache.org/systest/jaxws", "HelloContinuationService");
+    static final QName HELLO_PORT = 
+        new QName("http://cxf.apache.org/systest/jaxws", "HelloContinuationPort");
+    public HelloContinuationService(URL wsdlLocation, QName serviceName) {
+        super(wsdlLocation, serviceName);
+    }
+
+    @WebEndpoint(name = "HelloContinuationPort")
+    public HelloContinuation getHelloContinuationPort() {
+        return (HelloContinuation)super.getPort(HELLO_PORT, HelloContinuation.class);
+    }
+
+}

Propchange: cxf/trunk/systests/transport-jms/src/test/java/org/apache/cxf/systest/jms/continuations/HelloContinuationService.java
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: cxf/trunk/systests/transport-jms/src/test/java/org/apache/cxf/systest/jms/continuations/HelloContinuationService.java
------------------------------------------------------------------------------
    svn:keywords = Rev Date

Modified: cxf/trunk/systests/transport-jms/src/test/java/org/apache/cxf/systest/jms/continuations/HelloWorker.java
URL: http://svn.apache.org/viewvc/cxf/trunk/systests/transport-jms/src/test/java/org/apache/cxf/systest/jms/continuations/HelloWorker.java?rev=1133913&r1=1133912&r2=1133913&view=diff
==============================================================================
--- cxf/trunk/systests/transport-jms/src/test/java/org/apache/cxf/systest/jms/continuations/HelloWorker.java (original)
+++ cxf/trunk/systests/transport-jms/src/test/java/org/apache/cxf/systest/jms/continuations/HelloWorker.java Thu Jun  9 15:08:22 2011
@@ -1,67 +1,67 @@
-/**
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied. See the License for the
- * specific language governing permissions and limitations
- * under the License.
- */
-
-package org.apache.cxf.systest.jms.continuations;
-
-import java.util.concurrent.CountDownLatch;
-
-import org.junit.Assert;
-
-public class HelloWorker implements Runnable {
-
-    private HelloContinuation helloPort;
-    private String firstName;
-    private String secondName;
-    private CountDownLatch startSignal;
-    private CountDownLatch doneSignal;
-    public HelloWorker(HelloContinuation helloPort,
-                       String firstName,
-                       String secondName,
-                       CountDownLatch startSignal,
-                       CountDownLatch doneSignal) {
-        this.helloPort = helloPort;
-        this.firstName = firstName;
-        this.secondName = secondName;
-        this.startSignal = startSignal;
-        this.doneSignal = doneSignal;
-    }
-    
-    public void run() {
-        StringBuilder expected = new StringBuilder();
-        expected.append(firstName);
-        if (secondName != null && secondName.length() > 0) {
-            expected.append(' ').append(secondName);
-        }
-        
-        try {
-            startSignal.await();
-            
-            Assert.assertEquals("Wrong hello", "Hi " + expected.toString(), 
-                                helloPort.sayHi(firstName, secondName));
-            doneSignal.countDown();
-        } catch (InterruptedException ex) {
-            // ignore
-        } catch (RuntimeException ex) {
-            ex.printStackTrace();
-            Assert.fail("Hello thread failed for : " + expected.toString());
-        } 
-        
-    }
-    
-}
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+
+package org.apache.cxf.systest.jms.continuations;
+
+import java.util.concurrent.CountDownLatch;
+
+import org.junit.Assert;
+
+public class HelloWorker implements Runnable {
+
+    private HelloContinuation helloPort;
+    private String firstName;
+    private String secondName;
+    private CountDownLatch startSignal;
+    private CountDownLatch doneSignal;
+    public HelloWorker(HelloContinuation helloPort,
+                       String firstName,
+                       String secondName,
+                       CountDownLatch startSignal,
+                       CountDownLatch doneSignal) {
+        this.helloPort = helloPort;
+        this.firstName = firstName;
+        this.secondName = secondName;
+        this.startSignal = startSignal;
+        this.doneSignal = doneSignal;
+    }
+    
+    public void run() {
+        StringBuilder expected = new StringBuilder();
+        expected.append(firstName);
+        if (secondName != null && secondName.length() > 0) {
+            expected.append(' ').append(secondName);
+        }
+        
+        try {
+            startSignal.await();
+            
+            Assert.assertEquals("Wrong hello", "Hi " + expected.toString(), 
+                                helloPort.sayHi(firstName, secondName));
+            doneSignal.countDown();
+        } catch (InterruptedException ex) {
+            // ignore
+        } catch (RuntimeException ex) {
+            ex.printStackTrace();
+            Assert.fail("Hello thread failed for : " + expected.toString());
+        } 
+        
+    }
+    
+}

Propchange: cxf/trunk/systests/transport-jms/src/test/java/org/apache/cxf/systest/jms/continuations/HelloWorker.java
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: cxf/trunk/systests/transport-jms/src/test/java/org/apache/cxf/systest/jms/continuations/HelloWorker.java
------------------------------------------------------------------------------
    svn:keywords = Rev Date



Mime
View raw message