cxf-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From cschnei...@apache.org
Subject svn commit: r1089887 [2/6] - in /cxf/trunk/systests: ./ transport-jms/ transport-jms/src/ transport-jms/src/test/ transport-jms/src/test/java/ transport-jms/src/test/java/org/ transport-jms/src/test/java/org/apache/ transport-jms/src/test/java/org/apac...
Date Thu, 07 Apr 2011 14:11:54 GMT
Added: cxf/trunk/systests/transport-jms/src/test/java/org/apache/cxf/jms/testsuite/services/Test1108Impl.java
URL: http://svn.apache.org/viewvc/cxf/trunk/systests/transport-jms/src/test/java/org/apache/cxf/jms/testsuite/services/Test1108Impl.java?rev=1089887&view=auto
==============================================================================
--- cxf/trunk/systests/transport-jms/src/test/java/org/apache/cxf/jms/testsuite/services/Test1108Impl.java (added)
+++ cxf/trunk/systests/transport-jms/src/test/java/org/apache/cxf/jms/testsuite/services/Test1108Impl.java Thu Apr  7 14:11:51 2011
@@ -0,0 +1,39 @@
+/**
+ * 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.jms.testsuite.services;
+
+import org.apache.cxf.jms_simple.JMSSimplePortType;
+
+@javax.jws.WebService(portName = "SimplePort", 
+                      serviceName = "JMSSimpleService1108",
+                      targetNamespace = "http://cxf.apache.org/jms_simple",
+                      endpointInterface = "org.apache.cxf.jms_simple.JMSSimplePortType",
+                      wsdlLocation = "testutils/jms_spec_testsuite.wsdl")
+public class Test1108Impl implements JMSSimplePortType {
+
+    /** {@inheritDoc}*/
+    public String echo(String in) {
+        return in;
+    }
+
+    /** {@inheritDoc}*/
+    public void ping(String in) {
+    }
+}

Added: cxf/trunk/systests/transport-jms/src/test/java/org/apache/cxf/jms/testsuite/testcases/AbstractSOAPJMSTestSuite.java
URL: http://svn.apache.org/viewvc/cxf/trunk/systests/transport-jms/src/test/java/org/apache/cxf/jms/testsuite/testcases/AbstractSOAPJMSTestSuite.java?rev=1089887&view=auto
==============================================================================
--- cxf/trunk/systests/transport-jms/src/test/java/org/apache/cxf/jms/testsuite/testcases/AbstractSOAPJMSTestSuite.java (added)
+++ cxf/trunk/systests/transport-jms/src/test/java/org/apache/cxf/jms/testsuite/testcases/AbstractSOAPJMSTestSuite.java Thu Apr  7 14:11:51 2011
@@ -0,0 +1,253 @@
+/**
+ * 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.jms.testsuite.testcases;
+
+import java.lang.reflect.Constructor;
+import java.net.URL;
+
+import javax.jms.Destination;
+import javax.jms.JMSException;
+import javax.jms.Message;
+import javax.jms.Session;
+import javax.xml.namespace.QName;
+import javax.xml.ws.Service;
+
+import org.apache.cxf.BusFactory;
+import org.apache.cxf.jms.testsuite.util.JMSTestUtil;
+import org.apache.cxf.testsuite.testcase.MessagePropertiesType;
+import org.apache.cxf.testsuite.testcase.TestCaseType;
+import org.apache.cxf.testutil.common.AbstractBusClientServerTestBase;
+import org.apache.cxf.testutil.common.EmbeddedJMSBrokerLauncher;
+import org.apache.cxf.transport.jms.JMSConfiguration;
+import org.apache.cxf.transport.jms.JMSFactory;
+import org.apache.cxf.transport.jms.JMSMessageHeadersType;
+import org.apache.cxf.transport.jms.spec.JMSSpecConstants;
+import org.springframework.jms.core.JmsTemplate;
+import org.springframework.jms.core.MessageCreator;
+
+/**
+ * 
+ */
+public abstract class AbstractSOAPJMSTestSuite extends AbstractBusClientServerTestBase {
+
+    /**
+     * 
+     */
+    public AbstractSOAPJMSTestSuite() {
+        super();
+    }
+
+    public <T1, T2> T2 getPort(String serviceName, String portName, Class<T1> serviceClass,
+                               Class<T2> portTypeClass) throws Exception {
+        String namespace = "http://cxf.apache.org/jms_simple";
+        QName qServiceName = new QName(namespace, serviceName);
+        QName qPortName = new QName(namespace, portName);
+        URL wsdl = getClass().getResource("/wsdl/jms_spec_testsuite.wsdl");
+        String wsdlString = wsdl.toString();
+        EmbeddedJMSBrokerLauncher.updateWsdlExtensors(getBus(), wsdlString);
+        BusFactory.setThreadDefaultBus(getBus());
+        BusFactory.setDefaultBus(getBus());
+        Class<? extends Service> svcls = serviceClass.asSubclass(Service.class);
+
+        Constructor<? extends Service> serviceConstructor = svcls.getConstructor(URL.class,
+                                                                                 QName.class);
+        Service service = serviceConstructor.newInstance(new Object[] {
+            wsdl, qServiceName
+        });
+        return service.getPort(qPortName, portTypeClass);
+    }
+
+    public void checkJMSProperties(Message message, MessagePropertiesType messageProperties)
+        throws JMSException {
+        // todo messagetype
+        // todo messageid
+        if (messageProperties.isSetDeliveryMode()) {
+            assertEquals(message.getJMSDeliveryMode(), messageProperties.getDeliveryMode()
+                .intValue());
+        }
+        if (messageProperties.isSetPriority()) {
+            assertEquals(message.getJMSPriority(), messageProperties.getPriority().intValue());
+        }
+        if (messageProperties.isSetExpiration()) {
+            assertEquals(message.getJMSExpiration(), messageProperties.getExpiration().intValue());
+        }
+        if (messageProperties.isSetReplyTo() && !messageProperties.getReplyTo().trim().equals("")) {
+            assertEquals(message.getJMSReplyTo().toString(), messageProperties.getReplyTo());
+        }
+        if (messageProperties.isSetCorrelationID()
+            && !messageProperties.getCorrelationID().trim().equals("")) {
+            assertEquals(message.getJMSCorrelationID(), messageProperties.getCorrelationID());
+        }
+        if (messageProperties.isSetDestination()
+            && !messageProperties.getDestination().trim().equals("")) {
+            assertEquals(message.getJMSDestination().toString(), messageProperties.getDestination());
+        }
+        if (messageProperties.isSetRedelivered()) {
+            assertEquals(message.getJMSRedelivered(), messageProperties.isRedelivered());
+        }
+        if (messageProperties.isSetBindingVersion()
+            && !messageProperties.getBindingVersion().trim().equals("")) {
+            assertEquals(message.getStringProperty(JMSSpecConstants.BINDINGVERSION_FIELD),
+                         messageProperties.getBindingVersion());
+        }
+        if (messageProperties.isSetTargetService()
+            && !messageProperties.getTargetService().trim().equals("")) {
+            assertEquals(message.getStringProperty(JMSSpecConstants.TARGETSERVICE_FIELD),
+                         messageProperties.getTargetService());
+        }
+        if (messageProperties.isSetContentType()
+            && !messageProperties.getContentType().trim().equals("")) {
+            assertEquals(message.getStringProperty(JMSSpecConstants.CONTENTTYPE_FIELD),
+                         messageProperties.getContentType());
+        }
+        if (messageProperties.isSetSoapAction()
+            && !messageProperties.getSoapAction().trim().equals("")) {
+            assertEquals(message.getStringProperty(JMSSpecConstants.SOAPACTION_FIELD),
+                         messageProperties.getSoapAction());
+        }
+        if (messageProperties.isSetRequestURI()
+            && !messageProperties.getRequestURI().trim().equals("")) {
+            assertEquals(message.getStringProperty(JMSSpecConstants.REQUESTURI_FIELD),
+                         messageProperties.getRequestURI().trim());
+        }
+        if (messageProperties.isSetIsFault()) {
+            assertEquals(message.getBooleanProperty(JMSSpecConstants.ISFAULT_FIELD),
+                         messageProperties.isIsFault());
+        }
+        // todo messagebody
+    }
+
+    public void checkJMSProperties(TestCaseType testcase, JMSMessageHeadersType requestHeader)
+        throws JMSException {
+        if (testcase.getRequestMessage() != null) {
+            checkJMSProperties(testcase.getRequestMessage(), requestHeader);
+        }
+    }
+
+    public void checkJMSProperties(TestCaseType testcase, JMSMessageHeadersType requestHeader,
+                                   JMSMessageHeadersType responseHeader) throws JMSException {
+        if (testcase.getRequestMessage() != null) {
+            checkJMSProperties(testcase.getRequestMessage(), requestHeader);
+        }
+        if (testcase.getResponseMessage() != null) {
+            checkJMSProperties(testcase.getResponseMessage(), responseHeader);
+        }
+        if (requestHeader.getJMSCorrelationID() != null) {
+            assertEquals(requestHeader.getJMSCorrelationID(), responseHeader.getJMSCorrelationID());
+        } else {
+            assertEquals(requestHeader.getJMSMessageID(), responseHeader.getJMSCorrelationID());
+        }
+    }
+
+    private void checkJMSProperties(MessagePropertiesType messageProperties,
+                                    JMSMessageHeadersType header) {
+        // todo messagetype
+        // todo messageid
+        if (messageProperties.isSetDeliveryMode()) {
+            int dm = 0;
+            if (header.isSetJMSDeliveryMode()) {
+                dm = header.getJMSDeliveryMode();
+            }
+            assertEquals(dm, 
+                         messageProperties.getDeliveryMode().intValue());
+        }
+        if (messageProperties.isSetPriority()) {
+            assertEquals(header.getJMSPriority(), messageProperties.getPriority().intValue());
+        }
+        /*
+         * if (messageProperties.isSetExpiration()) { assertEquals(header.getJMSExpiration(),
+         * messageProperties.getExpiration().intValue()); }
+         */
+        /*
+         * if (messageProperties.isSetReplyTo() && !messageProperties.getReplyTo().trim().equals("")) {
+         * assertEquals(header.getJMSReplyTo().toString(), messageProperties.getReplyTo()); }
+         */
+        // correlationid
+        /*
+         * if (messageProperties.isSetDestination() && !messageProperties.getDestination().trim().equals(""))
+         * { assertEquals(header.get.toString(), messageProperties.getDestination()); }
+         */
+        if (messageProperties.isSetBindingVersion()
+            && !messageProperties.getBindingVersion().trim().equals("")) {
+            assertEquals(header.getSOAPJMSBindingVersion(), messageProperties.getBindingVersion());
+        }
+        if (messageProperties.isSetTargetService()
+            && !messageProperties.getTargetService().trim().equals("")) {
+            assertEquals(header.getSOAPJMSTargetService(), messageProperties.getTargetService());
+        }
+        if (messageProperties.isSetContentType()
+            && !messageProperties.getContentType().trim().equals("")) {
+            assertEquals(header.getSOAPJMSContentType(), messageProperties.getContentType());
+        }
+        if (messageProperties.isSetSoapAction()
+            && !messageProperties.getSoapAction().trim().equals("")) {
+            assertEquals(header.getSOAPJMSSOAPAction(), messageProperties.getSoapAction());
+        }
+        if (messageProperties.isSetRequestURI()
+            && !messageProperties.getRequestURI().trim().equals("")) {
+            assertEquals(header.getSOAPJMSRequestURI(), messageProperties.getRequestURI().trim());
+        }
+        if (messageProperties.isSetIsFault()) {
+            assertEquals(header.isSOAPJMSIsFault(), messageProperties.isIsFault());
+        }
+        // todo messagebody
+    }
+    
+    public void twoWayTestWithCreateMessage(final TestCaseType testcase) throws Exception {
+        String address = testcase.getAddress();
+        JMSConfiguration jmsConfig = JMSTestUtil.getInitJMSConfiguration(address);
+        final JmsTemplate jmsTemplate = JMSFactory.createJmsTemplate(jmsConfig, null);
+        
+        final Destination replyToDestination = JMSFactory.resolveOrCreateDestination(jmsTemplate,
+                                                                                     null, false);
+        class JMSConduitMessageCreator implements MessageCreator {
+            private javax.jms.Message jmsMessage;
+
+            public javax.jms.Message createMessage(Session session) throws JMSException {
+                jmsMessage = JMSTestUtil.buildJMSMessageFromTestCase(testcase, session, replyToDestination);
+                return jmsMessage;
+            }
+
+            public String getMessageID() {
+                if (jmsMessage != null) {
+                    try {
+                        return jmsMessage.getJMSMessageID();
+                    } catch (JMSException e) {
+                        return null;
+                    }
+                }
+                return null;
+            }
+        }
+        JMSConduitMessageCreator messageCreator = new JMSConduitMessageCreator();    
+
+        jmsTemplate.send(jmsConfig.getTargetDestination(), messageCreator);
+        String messageId = messageCreator.getMessageID();
+
+        String messageSelector = "JMSCorrelationID = '" + messageId + "'";
+        javax.jms.Message replyMessage = jmsTemplate.receiveSelected(replyToDestination,
+                                                                     messageSelector);
+        checkReplyMessage(replyMessage, testcase);
+    }
+
+    private void checkReplyMessage(Message replyMessage, TestCaseType testcase) throws JMSException {
+        checkJMSProperties(replyMessage, testcase.getResponseMessage());
+    }
+}

Added: cxf/trunk/systests/transport-jms/src/test/java/org/apache/cxf/jms/testsuite/testcases/SOAPJMSTestSuiteTest.java
URL: http://svn.apache.org/viewvc/cxf/trunk/systests/transport-jms/src/test/java/org/apache/cxf/jms/testsuite/testcases/SOAPJMSTestSuiteTest.java?rev=1089887&view=auto
==============================================================================
--- cxf/trunk/systests/transport-jms/src/test/java/org/apache/cxf/jms/testsuite/testcases/SOAPJMSTestSuiteTest.java (added)
+++ cxf/trunk/systests/transport-jms/src/test/java/org/apache/cxf/jms/testsuite/testcases/SOAPJMSTestSuiteTest.java Thu Apr  7 14:11:51 2011
@@ -0,0 +1,456 @@
+/**
+ * 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.jms.testsuite.testcases;
+
+import java.lang.reflect.InvocationHandler;
+import java.lang.reflect.Proxy;
+import java.util.HashMap;
+import java.util.Map;
+
+import javax.jms.DeliveryMode;
+import javax.xml.ws.BindingProvider;
+import javax.xml.ws.WebServiceException;
+
+import org.apache.cxf.jms.testsuite.services.Server;
+import org.apache.cxf.jms.testsuite.util.JMSTestUtil;
+import org.apache.cxf.jms_simple.JMSSimplePortType;
+import org.apache.cxf.jms_simple.JMSSimpleService0001;
+import org.apache.cxf.jms_simple.JMSSimpleService0003;
+import org.apache.cxf.jms_simple.JMSSimpleService0005;
+import org.apache.cxf.jms_simple.JMSSimpleService0006;
+import org.apache.cxf.jms_simple.JMSSimpleService0008;
+import org.apache.cxf.jms_simple.JMSSimpleService0009;
+import org.apache.cxf.jms_simple.JMSSimpleService0010;
+import org.apache.cxf.jms_simple.JMSSimpleService0011;
+import org.apache.cxf.jms_simple.JMSSimpleService0012;
+import org.apache.cxf.jms_simple.JMSSimpleService0013;
+import org.apache.cxf.jms_simple.JMSSimpleService0014;
+import org.apache.cxf.jms_simple.JMSSimpleService0101;
+import org.apache.cxf.jms_simple.JMSSimpleService1001;
+import org.apache.cxf.jms_simple.JMSSimpleService1009;
+import org.apache.cxf.jms_simple.JMSSimpleService1101;
+import org.apache.cxf.jms_simple.JMSSimpleService1105;
+import org.apache.cxf.jms_simple.JMSSimpleService1109;
+import org.apache.cxf.testsuite.testcase.TestCaseType;
+import org.apache.cxf.testutil.common.EmbeddedJMSBrokerLauncher;
+import org.apache.cxf.transport.jms.JMSConstants;
+import org.apache.cxf.transport.jms.JMSMessageHeadersType;
+
+import org.junit.BeforeClass;
+import org.junit.Test;
+
+/**
+ * 
+ */
+public class SOAPJMSTestSuiteTest extends AbstractSOAPJMSTestSuite {
+    static final String JMS_PORT = EmbeddedJMSBrokerLauncher.PORT;
+    
+    @BeforeClass
+    public static void startServers() throws Exception {
+        Map<String, String> props = new HashMap<String, String>();
+        if (System.getProperty("org.apache.activemq.default.directory.prefix") != null) {
+            props.put("org.apache.activemq.default.directory.prefix", 
+                      System.getProperty("org.apache.activemq.default.directory.prefix"));
+        }
+        props.put("java.util.logging.config.file", System
+            .getProperty("java.util.logging.config.file"));
+        assertTrue("server did not launch correctly", launchServer(EmbeddedJMSBrokerLauncher.class,
+                                                                   props, null));
+        assertTrue("server did not launch correctly", launchServer(Server.class, false));
+        createStaticBus();
+    }
+    
+    private void oneWayTest(TestCaseType testcase, JMSSimplePortType port) throws Exception {
+        InvocationHandler handler = Proxy.getInvocationHandler(port);
+        BindingProvider bp = (BindingProvider)handler;
+
+        Map<String, Object> requestContext = bp.getRequestContext();
+        JMSMessageHeadersType requestHeader = new JMSMessageHeadersType();
+
+        requestContext.put(JMSConstants.JMS_CLIENT_REQUEST_HEADERS, requestHeader);
+        Exception e = null;
+        try {
+            port.ping("test");
+        } catch (Exception e1) {
+            e = e1;
+        }
+        checkJMSProperties(testcase, requestHeader);
+        if (e != null) {
+            throw e;
+        }
+    }
+
+    private void twoWayTest(TestCaseType testcase, final JMSSimplePortType port)
+        throws Exception {
+        JMSMessageHeadersType requestHeader = new JMSMessageHeadersType();
+        twoWayTestWithRequestHeader(testcase, port, requestHeader);
+    }
+
+    private void twoWayTestWithRequestHeader(TestCaseType testcase, final JMSSimplePortType port,
+                                             JMSMessageHeadersType requestHeader)
+        throws Exception {
+        InvocationHandler handler = Proxy.getInvocationHandler(port);
+        BindingProvider bp = (BindingProvider)handler;
+
+        Map<String, Object> requestContext = bp.getRequestContext();
+        if (requestHeader == null) {
+            requestHeader = new JMSMessageHeadersType();
+        }
+        requestContext.put(JMSConstants.JMS_CLIENT_REQUEST_HEADERS, requestHeader);
+        Exception e = null;
+        try {
+            String response = port.echo("test");
+            assertEquals(response, "test");
+        } catch (WebServiceException ew) {
+            throw ew;
+        } catch (Exception e1) {
+            e = e1;
+        }
+        Map<String, Object> responseContext = bp.getResponseContext();
+        JMSMessageHeadersType responseHeader = (JMSMessageHeadersType)responseContext
+            .get(JMSConstants.JMS_CLIENT_RESPONSE_HEADERS);
+        checkJMSProperties(testcase, requestHeader, responseHeader);
+        if (e != null) {
+            throw e;
+        }
+    }
+
+    @Test
+    public void test0001() throws Exception {
+        TestCaseType testcase = JMSTestUtil.getTestCase("test0001");
+        final JMSSimplePortType simplePort = getPort("JMSSimpleService0001", "SimplePort",
+                                                     JMSSimpleService0001.class,
+                                                     JMSSimplePortType.class);
+        oneWayTest(testcase, simplePort);
+    }
+
+    @Test
+    public void test0101() throws Exception {
+        TestCaseType testcase = JMSTestUtil.getTestCase("test0101");
+        final JMSSimplePortType simplePort = getPort("JMSSimpleService0101", "SimplePort",
+                                                     JMSSimpleService0101.class,
+                                                     JMSSimplePortType.class);
+        oneWayTest(testcase, simplePort);
+    }
+
+    @Test
+    public void test0002() throws Exception {
+        TestCaseType testcase = JMSTestUtil.getTestCase("test0002");
+        final JMSSimplePortType simplePort = getPort("JMSSimpleService0001", "SimplePort",
+                                                     JMSSimpleService0001.class,
+                                                     JMSSimplePortType.class);
+        JMSMessageHeadersType requestHeader = new JMSMessageHeadersType();
+        requestHeader.setJMSCorrelationID("Correlator0002");
+
+        twoWayTestWithRequestHeader(testcase, simplePort, requestHeader);
+    }
+
+    @Test
+    public void test0102() throws Exception {
+        TestCaseType testcase = JMSTestUtil.getTestCase("test0102");
+        final JMSSimplePortType simplePort = getPort("JMSSimpleService0101", "SimplePort",
+                                                     JMSSimpleService0101.class,
+                                                     JMSSimplePortType.class);
+        twoWayTest(testcase, simplePort);
+    }
+
+    @Test
+    public void test0003() throws Exception {
+        TestCaseType testcase = JMSTestUtil.getTestCase("test0003");
+        final JMSSimplePortType simplePort = getPort("JMSSimpleService0003", "SimplePort",
+                                                     JMSSimpleService0003.class,
+                                                     JMSSimplePortType.class);
+        oneWayTest(testcase, simplePort);
+    }
+
+    @Test
+    public void test0004() throws Exception {
+        TestCaseType testcase = JMSTestUtil.getTestCase("test0004");
+        final JMSSimplePortType simplePort = getPort("JMSSimpleService0003", "SimplePort",
+                                                     JMSSimpleService0003.class,
+                                                     JMSSimplePortType.class);
+        twoWayTest(testcase, simplePort);
+    }
+
+    @Test
+    public void test0005() throws Exception {
+        TestCaseType testcase = JMSTestUtil.getTestCase("test0005");
+        final JMSSimplePortType simplePort = getPort("JMSSimpleService0005", "SimplePort",
+                                                     JMSSimpleService0005.class,
+                                                     JMSSimplePortType.class);
+        twoWayTest(testcase, simplePort);
+    }
+
+    @Test
+    public void test0006() throws Exception {
+        TestCaseType testcase = JMSTestUtil.getTestCase("test0006");
+        final JMSSimplePortType simplePort = getPort("JMSSimpleService0006", "SimplePort",
+                                                     JMSSimpleService0006.class,
+                                                     JMSSimplePortType.class);
+        twoWayTest(testcase, simplePort);
+    }
+
+    @Test
+    public void test0008() throws Exception {
+        TestCaseType testcase = JMSTestUtil.getTestCase("test0008");
+        final JMSSimplePortType simplePort = getPort("JMSSimpleService0008", "SimplePort",
+                                                     JMSSimpleService0008.class,
+                                                     JMSSimplePortType.class);
+
+        JMSMessageHeadersType requestHeader = new JMSMessageHeadersType();
+        requestHeader.setJMSDeliveryMode(DeliveryMode.NON_PERSISTENT);
+        requestHeader.setTimeToLive(14400000);
+        requestHeader.setJMSPriority(8);
+        requestHeader.setJMSReplyTo("dynamicQueues/replyqueue0008");
+
+        twoWayTestWithRequestHeader(testcase, simplePort, requestHeader);
+    }
+
+    @Test
+    public void test0009() throws Exception {
+        TestCaseType testcase = JMSTestUtil.getTestCase("test0009");
+        final JMSSimplePortType simplePort = getPort("JMSSimpleService0009", "SimplePort",
+                                                     JMSSimpleService0009.class,
+                                                     JMSSimplePortType.class);
+
+        JMSMessageHeadersType requestHeader = new JMSMessageHeadersType();
+        requestHeader.setJMSDeliveryMode(DeliveryMode.NON_PERSISTENT);
+        requestHeader.setTimeToLive(10800000);
+        requestHeader.setJMSPriority(3);
+        requestHeader.setJMSReplyTo("dynamicQueues/replyqueue00093");
+
+        twoWayTestWithRequestHeader(testcase, simplePort, requestHeader);
+    }
+
+    @Test
+    public void test0010() throws Exception {
+        TestCaseType testcase = JMSTestUtil.getTestCase("test0010");
+        final JMSSimplePortType simplePort = getPort("JMSSimpleService0010", "SimplePort",
+                                                     JMSSimpleService0010.class,
+                                                     JMSSimplePortType.class);
+        twoWayTest(testcase, simplePort);
+    }
+
+    @Test
+    public void test0011() throws Exception {
+        TestCaseType testcase = JMSTestUtil.getTestCase("test0011");
+        final JMSSimplePortType simplePort = getPort("JMSSimpleService0011", "SimplePort",
+                                                     JMSSimpleService0011.class,
+                                                     JMSSimplePortType.class);
+        twoWayTest(testcase, simplePort);
+    }
+
+    @Test
+    public void test0012() throws Exception {
+        // same to test0002
+        TestCaseType testcase = JMSTestUtil.getTestCase("test0012");
+        final JMSSimplePortType simplePort = getPort("JMSSimpleService0012", "SimplePort",
+                                                     JMSSimpleService0012.class,
+                                                     JMSSimplePortType.class);
+        twoWayTest(testcase, simplePort);
+    }
+
+    @Test
+    public void test0013() throws Exception {
+        // same to test0002
+        TestCaseType testcase = JMSTestUtil.getTestCase("test0013");
+        final JMSSimplePortType simplePort = getPort("JMSSimpleService0013", "SimplePort",
+                                                     JMSSimpleService0013.class,
+                                                     JMSSimplePortType.class);
+        twoWayTest(testcase, simplePort);
+    }
+
+    @Test
+    public void test0014() throws Exception {
+        // same to test0002
+        TestCaseType testcase = JMSTestUtil.getTestCase("test0014");
+        final JMSSimplePortType simplePort = getPort("JMSSimpleService0014", "SimplePort",
+                                                     JMSSimpleService0014.class,
+                                                     JMSSimplePortType.class);
+        twoWayTest(testcase, simplePort);
+    }
+
+    @Test
+    public void test1001() throws Exception {
+        // same to test0002
+        TestCaseType testcase = JMSTestUtil.getTestCase("test1001");
+        final JMSSimplePortType simplePort = getPort("JMSSimpleService1001", "SimplePort",
+                                                     JMSSimpleService1001.class,
+                                                     JMSSimplePortType.class);
+
+        JMSMessageHeadersType requestHeader = new JMSMessageHeadersType();
+        requestHeader.setSOAPJMSBindingVersion("0.3");
+        try {
+            twoWayTestWithRequestHeader(testcase, simplePort, requestHeader);
+        } catch (Exception e) {
+            assertTrue(e.getMessage().contains("Unrecognized BindingVersion"));
+        }
+    }
+    
+    @Test
+    public void test1002() throws Exception {
+        TestCaseType testcase = JMSTestUtil.getTestCase("test1002");
+        
+        twoWayTestWithCreateMessage(testcase);
+    }
+    
+    @Test
+    public void test1003() throws Exception {
+        TestCaseType testcase = JMSTestUtil.getTestCase("test1003");
+        
+        twoWayTestWithCreateMessage(testcase);
+    }
+    
+    @Test
+    public void test1004() throws Exception {
+        TestCaseType testcase = JMSTestUtil.getTestCase("test1004");
+        
+        twoWayTestWithCreateMessage(testcase);
+    }
+    
+    @Test
+    public void test1006() throws Exception {
+        TestCaseType testcase = JMSTestUtil.getTestCase("test1006");
+        
+        twoWayTestWithCreateMessage(testcase);
+    }
+    
+    @Test
+    public void test1007() throws Exception {
+        TestCaseType testcase = JMSTestUtil.getTestCase("test1007");
+        
+        twoWayTestWithCreateMessage(testcase);
+    }
+    
+    @Test
+    public void test1008() throws Exception {
+        TestCaseType testcase = JMSTestUtil.getTestCase("test1008");
+        
+        twoWayTestWithCreateMessage(testcase);
+    }
+
+    @Test
+    public void test1009() throws Exception {
+        TestCaseType testcase = JMSTestUtil.getTestCase("test1009");
+        final JMSSimplePortType simplePort = getPort("JMSSimpleService1009", "SimplePort",
+                                                     JMSSimpleService1009.class,
+                                                     JMSSimplePortType.class);
+
+        JMSMessageHeadersType requestHeader = new JMSMessageHeadersType();
+        try {
+            twoWayTestWithRequestHeader(testcase, simplePort, requestHeader);
+        } catch (Exception e) {
+            assertTrue(e.getMessage().contains("Unknow JMS Variant"));
+        }
+    }
+
+    @Test
+    public void test1101() throws Exception {
+        // same to test0002
+        TestCaseType testcase = JMSTestUtil.getTestCase("test1101");
+        final JMSSimplePortType simplePort = getPort("JMSSimpleService1101", "SimplePort",
+                                                     JMSSimpleService1101.class,
+                                                     JMSSimplePortType.class);
+
+        JMSMessageHeadersType requestHeader = new JMSMessageHeadersType();
+        requestHeader.setSOAPJMSBindingVersion("0.3");
+        try {
+            twoWayTestWithRequestHeader(testcase, simplePort, requestHeader);
+        } catch (Exception e) {
+            assertTrue(e.getMessage().contains("Unrecognized BindingVersion"));
+        }
+    }
+    
+    @Test
+    public void test1102() throws Exception {
+        TestCaseType testcase = JMSTestUtil.getTestCase("test1102");
+        
+        twoWayTestWithCreateMessage(testcase);
+    }
+    
+    @Test
+    public void test1103() throws Exception {
+        TestCaseType testcase = JMSTestUtil.getTestCase("test1103");
+        
+        twoWayTestWithCreateMessage(testcase);
+    }
+    
+    @Test
+    public void test1104() throws Exception {
+        TestCaseType testcase = JMSTestUtil.getTestCase("test1104");
+        
+        twoWayTestWithCreateMessage(testcase);
+    }
+    
+    @Test
+    public void test1105() throws Exception {
+ 
+        TestCaseType testcase = JMSTestUtil.getTestCase("test1105");
+         
+        final JMSSimplePortType simplePort = getPort("JMSSimpleService1105", "SimplePort",
+                                                     JMSSimpleService1105.class,
+                                                     JMSSimplePortType.class);
+
+        JMSMessageHeadersType requestHeader = new JMSMessageHeadersType();
+        requestHeader.setSOAPJMSSOAPAction("mismatch");
+        try {
+            twoWayTestWithRequestHeader(testcase, simplePort, requestHeader);
+        } catch (Exception e) {
+            assertTrue(e.getMessage().contains("Mismatched SoapAction"));
+        }
+    }
+    
+    @Test
+    public void test1106() throws Exception {
+        TestCaseType testcase = JMSTestUtil.getTestCase("test1106");
+        
+        twoWayTestWithCreateMessage(testcase);
+    }
+    
+    @Test
+    public void test1107() throws Exception {
+        TestCaseType testcase = JMSTestUtil.getTestCase("test1107");
+        
+        twoWayTestWithCreateMessage(testcase);
+    }
+    
+    @Test
+    public void test1108() throws Exception {
+        TestCaseType testcase = JMSTestUtil.getTestCase("test1108");
+        
+        twoWayTestWithCreateMessage(testcase);
+    }
+    
+    @Test
+    public void test1109() throws Exception {
+        TestCaseType testcase = JMSTestUtil.getTestCase("test1109");
+        final JMSSimplePortType simplePort = getPort("JMSSimpleService1109", "SimplePort",
+                                                     JMSSimpleService1109.class,
+                                                     JMSSimplePortType.class);
+
+        JMSMessageHeadersType requestHeader = new JMSMessageHeadersType();
+        try {
+            twoWayTestWithRequestHeader(testcase, simplePort, requestHeader);
+        } catch (Exception e) {
+            assertTrue(e.getMessage().contains("Unknow JMS Variant"));
+        }
+    }
+
+}

Added: cxf/trunk/systests/transport-jms/src/test/java/org/apache/cxf/jms/testsuite/util/JMSTestUtil.java
URL: http://svn.apache.org/viewvc/cxf/trunk/systests/transport-jms/src/test/java/org/apache/cxf/jms/testsuite/util/JMSTestUtil.java?rev=1089887&view=auto
==============================================================================
--- cxf/trunk/systests/transport-jms/src/test/java/org/apache/cxf/jms/testsuite/util/JMSTestUtil.java (added)
+++ cxf/trunk/systests/transport-jms/src/test/java/org/apache/cxf/jms/testsuite/util/JMSTestUtil.java Thu Apr  7 14:11:51 2011
@@ -0,0 +1,243 @@
+/**
+ * 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.jms.testsuite.util;
+
+import java.util.ArrayList;
+import java.util.Iterator;
+import java.util.List;
+
+import javax.jms.DeliveryMode;
+import javax.jms.Destination;
+import javax.jms.JMSException;
+import javax.jms.Message;
+import javax.jms.Session;
+import javax.jms.StreamMessage;
+import javax.jms.TextMessage;
+import javax.xml.bind.JAXBContext;
+import javax.xml.bind.JAXBElement;
+import javax.xml.bind.Unmarshaller;
+
+import org.apache.cxf.testsuite.testcase.MessagePropertiesType;
+import org.apache.cxf.testsuite.testcase.TestCaseType;
+import org.apache.cxf.testsuite.testcase.TestCasesType;
+import org.apache.cxf.testutil.common.EmbeddedJMSBrokerLauncher;
+import org.apache.cxf.transport.jms.JMSConfiguration;
+import org.apache.cxf.transport.jms.JMSFactory;
+import org.apache.cxf.transport.jms.JMSOldConfigHolder;
+import org.apache.cxf.transport.jms.JNDIConfiguration;
+import org.apache.cxf.transport.jms.spec.JMSSpecConstants;
+import org.apache.cxf.transport.jms.uri.JMSEndpoint;
+import org.apache.cxf.transport.jms.uri.JMSEndpointParser;
+import org.apache.cxf.transport.jms.uri.JMSURIConstants;
+import org.springframework.jms.core.JmsTemplate;
+import org.springframework.jms.support.destination.JndiDestinationResolver;
+import org.springframework.jndi.JndiTemplate;
+
+/**
+ * 
+ */
+public final class JMSTestUtil {
+
+    private static TestCasesType testcases;
+
+    private JMSTestUtil() {
+    }
+    
+    public static List<TestCaseType> getTestCases() {
+        try {
+            if (testcases == null) {
+                loadTestCases();
+            }
+            return testcases.getTestCase();
+        } catch (Exception e) {
+            e.printStackTrace();
+        }
+        return new ArrayList<TestCaseType>();
+    }
+
+    public static TestCaseType getTestCase(String testId) {
+        if (testId == null) {
+            return null;
+        }
+        Iterator<TestCaseType> iter = getTestCases().iterator();
+        while (iter.hasNext()) {
+            TestCaseType testcase = iter.next();
+            if (testId.equals(testcase.getId())) {
+                return testcase;
+            }
+        }
+        return null;
+    }
+
+    private static void loadTestCases() throws Exception {
+        JAXBContext context = JAXBContext.newInstance("org.apache.cxf.testsuite.testcase");
+        Unmarshaller unmarshaller = context.createUnmarshaller();
+        JAXBElement e = (JAXBElement)unmarshaller.unmarshal(new JMSTestUtil().getClass()
+            .getResource("/org/apache/cxf/jms/testsuite/util/testcases.xml"));
+        testcases = (TestCasesType)e.getValue();
+        for (TestCaseType tct : testcases.getTestCase()) {
+            if (tct.isSetAddress()) {
+                String add = tct.getAddress();
+                int idx = add.indexOf("jndiURL=");
+                if (idx != -1) {
+                    int idx2 = add.indexOf("&", idx);
+                    add = add.substring(0, idx)
+                        + "jndiURL=tcp://localhost:" + EmbeddedJMSBrokerLauncher.PORT
+                        + (idx2 == -1 ? "" : add.substring(idx2));
+                    tct.setAddress(add);
+                }
+            }
+        }
+    }
+
+    public static JmsTemplate getJmsTemplate(String address) throws Exception {
+        return JMSFactory.createJmsTemplate(getInitJMSConfiguration(address), null);
+    }
+
+    public static Destination getJmsDestination(JmsTemplate jmsTemplate, String destinationName,
+                                                boolean pubSubDomain) {
+        return JMSFactory.resolveOrCreateDestination(jmsTemplate, destinationName, pubSubDomain);
+    }
+
+    public static JMSConfiguration getInitJMSConfiguration(String address) throws Exception {
+        JMSEndpoint endpoint = JMSEndpointParser.createEndpoint(address);
+
+        JMSConfiguration jmsConfig = new JMSConfiguration();
+
+        if (endpoint.isSetDeliveryMode()) {
+            int deliveryMode = endpoint.getDeliveryMode()
+                .equals(JMSURIConstants.DELIVERYMODE_PERSISTENT)
+                ? DeliveryMode.PERSISTENT : DeliveryMode.NON_PERSISTENT;
+            jmsConfig.setDeliveryMode(deliveryMode);
+        }
+
+        if (endpoint.isSetPriority()) {
+            int priority = endpoint.getPriority();
+            jmsConfig.setPriority(priority);
+        }
+
+        if (endpoint.isSetTimeToLive()) {
+            long timeToLive = endpoint.getTimeToLive();
+            jmsConfig.setTimeToLive(timeToLive);
+        }
+
+        if (jmsConfig.isUsingEndpointInfo()) {
+            JndiTemplate jt = new JndiTemplate();
+            jt.setEnvironment(JMSOldConfigHolder.getInitialContextEnv(endpoint));
+            boolean pubSubDomain = false;
+            pubSubDomain = endpoint.getJmsVariant().equals(JMSURIConstants.TOPIC);
+            JNDIConfiguration jndiConfig = new JNDIConfiguration();
+            jndiConfig.setJndiConnectionFactoryName(endpoint.getJndiConnectionFactoryName());
+            jmsConfig.setJndiTemplate(jt);
+            jmsConfig.setJndiConfig(jndiConfig);
+            jmsConfig.setExplicitQosEnabled(true);
+            jmsConfig.setPubSubDomain(pubSubDomain);
+            jmsConfig.setPubSubNoLocal(true);
+            boolean useJndi = endpoint.getJmsVariant().equals(JMSURIConstants.JNDI);
+            if (useJndi) {
+                // Setup Destination jndi destination resolver
+                final JndiDestinationResolver jndiDestinationResolver = new JndiDestinationResolver();
+                jndiDestinationResolver.setJndiTemplate(jt);
+                jmsConfig.setDestinationResolver(jndiDestinationResolver);
+                jmsConfig.setTargetDestination(endpoint.getDestinationName());
+                jmsConfig.setReplyDestination(endpoint.getReplyToName());
+            } else {
+                // Use the default dynamic destination resolver
+                jmsConfig.setTargetDestination(endpoint.getDestinationName());
+                jmsConfig.setReplyDestination(endpoint.getReplyToName());
+            }
+        }
+        return jmsConfig;
+    }
+
+    /**
+     * @param testcase
+     * @param session
+     * @param rtd
+     * @return
+     * @throws JMSException 
+     */
+    public static Message buildJMSMessageFromTestCase(TestCaseType testcase, Session session,
+                                                      Destination rtd) throws JMSException {
+        MessagePropertiesType messageProperties = testcase.getRequestMessage();
+        Message jmsMessage = null;
+        String messageType = messageProperties.getMessageType();
+        if ("text".equals(messageType)) {
+            jmsMessage = session.createTextMessage();
+            ((TextMessage)jmsMessage).setText("test");
+        } else if ("byte".equals(messageType)) {
+            jmsMessage = session.createBytesMessage();
+        } else if ("stream".equals(messageType)) {
+            jmsMessage = session.createStreamMessage();
+            ((StreamMessage)jmsMessage).writeString("test");
+        } else {
+            jmsMessage = session.createBytesMessage();
+        }
+
+        jmsMessage.setJMSReplyTo(rtd);
+
+        if (messageProperties.isSetDeliveryMode()) {
+            jmsMessage.setJMSDeliveryMode(messageProperties.getDeliveryMode());
+        }
+        if (messageProperties.isSetExpiration()) {
+            jmsMessage.setJMSExpiration(messageProperties.getExpiration());
+        }
+        if (messageProperties.isSetPriority()) {
+            jmsMessage.setJMSPriority(messageProperties.getPriority());
+        }
+        if (messageProperties.isSetExpiration()) {
+            jmsMessage.setJMSPriority(messageProperties.getExpiration());
+        }
+        if (messageProperties.isSetCorrelationID()) {
+            jmsMessage.setJMSCorrelationID(messageProperties.getCorrelationID());
+        }
+        
+        if (messageProperties.isSetTargetService()
+            && !"".equals(messageProperties.getTargetService().trim())) {
+            jmsMessage.setStringProperty(JMSSpecConstants.TARGETSERVICE_FIELD, messageProperties
+                .getTargetService().trim());
+        }
+
+        if (messageProperties.isSetBindingVersion()
+            && !"".equals(messageProperties.getBindingVersion().trim())) {
+            jmsMessage.setStringProperty(JMSSpecConstants.BINDINGVERSION_FIELD, messageProperties
+                                         .getBindingVersion().trim());
+        }
+
+        if (messageProperties.isSetContentType()
+            && !"".equals(messageProperties.getContentType().trim())) {
+            jmsMessage.setStringProperty(JMSSpecConstants.CONTENTTYPE_FIELD, messageProperties
+                .getContentType().trim());
+        }
+
+        if (messageProperties.isSetSoapAction()
+            && !"".equals(messageProperties.getSoapAction().trim())) {
+            jmsMessage.setStringProperty(JMSSpecConstants.SOAPACTION_FIELD, messageProperties
+                .getSoapAction().trim());
+        }
+
+        if (messageProperties.isSetRequestURI()
+            && !"".equals(messageProperties.getRequestURI().trim())) {
+            jmsMessage.setStringProperty(JMSSpecConstants.REQUESTURI_FIELD, messageProperties
+                .getRequestURI().trim());
+        }
+        return jmsMessage;
+    }
+}

Added: cxf/trunk/systests/transport-jms/src/test/java/org/apache/cxf/jms/testsuite/util/testcases.xml
URL: http://svn.apache.org/viewvc/cxf/trunk/systests/transport-jms/src/test/java/org/apache/cxf/jms/testsuite/util/testcases.xml?rev=1089887&view=auto
==============================================================================
--- cxf/trunk/systests/transport-jms/src/test/java/org/apache/cxf/jms/testsuite/util/testcases.xml (added)
+++ cxf/trunk/systests/transport-jms/src/test/java/org/apache/cxf/jms/testsuite/util/testcases.xml Thu Apr  7 14:11:51 2011
@@ -0,0 +1,957 @@
+<?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.
+	-->
+<testCases xmlns="http://cxf.apache.org/jms/testcase/">
+	<testCase id="test0001" mep="inonly">
+		<address>jms:jndi:dynamicQueues/testqueue0001?jndiInitialContextFactory=org.apache.activemq.jndi.ActiveMQInitialContextFactory&amp;jndiConnectionFactoryName=ConnectionFactory&amp;jndiURL=tcp://localhost:61500</address>
+		<requestMessage>
+			<messageType>byte</messageType>
+			<deliveryMode>2</deliveryMode>
+			<priority>4</priority>
+			<expiration>0</expiration>
+			<replyTo></replyTo>
+			<correlationID></correlationID>
+			<destination>queue://testqueue0001</destination>
+			<redelivered>false</redelivered>
+			<bindingVersion>1.0</bindingVersion>
+			<targetService></targetService>
+			<contentType>text/xml; charset=UTF-8</contentType>
+			<soapAction></soapAction>
+			<requestURI>jms:jndi:dynamicQueues/testqueue0001
+			</requestURI>
+			<messageBody></messageBody>
+		</requestMessage>
+	</testCase>
+	
+	<testCase id="test0002" mep="inout">
+		<address>jms:jndi:dynamicQueues/testqueue0001?jndiInitialContextFactory=org.apache.activemq.jndi.ActiveMQInitialContextFactory&amp;jndiConnectionFactoryName=ConnectionFactory&amp;jndiURL=tcp://localhost:61500</address>
+		<requestMessage>
+			<messageType>byte</messageType>
+			<deliveryMode>2</deliveryMode>
+			<priority>4</priority>
+			<expiration>0</expiration>
+			<replyTo></replyTo>
+			<correlationID>Correlator0002</correlationID>
+			<destination>queue://testqueue0001</destination>
+			<redelivered>false</redelivered>
+			<bindingVersion>1.0</bindingVersion>
+			<targetService></targetService>
+			<contentType>text/xml; charset=UTF-8</contentType>
+			<soapAction></soapAction>
+			<requestURI>jms:jndi:dynamicQueues/testqueue0001
+			</requestURI>
+			<messageBody></messageBody>
+		</requestMessage>
+		<responseMessage>
+			<messageType>byte</messageType>
+			<deliveryMode>2</deliveryMode>
+			<priority>4</priority>
+			<expiration>0</expiration>
+			<replyTo></replyTo>
+			<correlationID>Correlator0002</correlationID>
+			<destination></destination>
+			<redelivered>false</redelivered>
+			<bindingVersion>1.0</bindingVersion>
+			<targetService></targetService>
+			<contentType>text/xml; charset=UTF-8</contentType>
+			<soapAction></soapAction>
+			<requestURI>jms:jndi:dynamicQueues/testqueue0001</requestURI>
+			<messageBody></messageBody>
+		</responseMessage>
+	</testCase>
+	
+	<testCase id="test0101" mep="inonly">
+		<address>jms:jndi:dynamicQueues/testqueue0101?jndiInitialContextFactory=org.apache.activemq.jndi.ActiveMQInitialContextFactory&amp;jndiConnectionFactoryName=ConnectionFactory&amp;jndiURL=tcp://localhost:61500</address>
+		<requestMessage>
+			<messageType>byte</messageType>
+			<deliveryMode>2</deliveryMode>
+			<priority>4</priority>
+			<expiration>0</expiration>
+			<replyTo></replyTo>
+			<correlationID></correlationID>
+			<destination>queue://testqueue0101</destination>
+			<redelivered>false</redelivered>
+			<bindingVersion>1.0</bindingVersion>
+			<targetService></targetService>
+			<contentType>application/soap+xml; charset=UTF-8</contentType>
+			<soapAction></soapAction>
+			<requestURI>jms:jndi:dynamicQueues/testqueue0101
+			</requestURI>
+			<messageBody></messageBody>
+		</requestMessage>
+	</testCase>
+	
+	<testCase id="test0102" mep="inout">
+		<address>jms:jndi:dynamicQueues/testqueue0101?jndiInitialContextFactory=org.apache.activemq.jndi.ActiveMQInitialContextFactory&amp;jndiConnectionFactoryName=ConnectionFactory&amp;jndiURL=tcp://localhost:61500</address>
+		<requestMessage>
+			<messageType>byte</messageType>
+			<deliveryMode>2</deliveryMode>
+			<priority>4</priority>
+			<expiration>0</expiration>
+			<replyTo></replyTo>
+			<correlationID>Correlator0002</correlationID>
+			<destination>queue://testqueue0101</destination>
+			<redelivered>false</redelivered>
+			<bindingVersion>1.0</bindingVersion>
+			<targetService></targetService>
+			<contentType>application/soap+xml; action="echo"; charset=UTF-8</contentType>
+			<soapAction></soapAction>
+			<requestURI>jms:jndi:dynamicQueues/testqueue0101
+			</requestURI>
+			<messageBody></messageBody>
+		</requestMessage>
+		<responseMessage>
+			<messageType>byte</messageType>
+			<deliveryMode>2</deliveryMode>
+			<priority>4</priority>
+			<expiration>0</expiration>
+			<replyTo></replyTo>
+			<correlationID>Correlator0002</correlationID>
+			<destination></destination>
+			<redelivered>false</redelivered>
+			<bindingVersion>1.0</bindingVersion>
+			<targetService></targetService>
+			<contentType>application/soap+xml; charset=UTF-8</contentType>
+			<soapAction></soapAction>
+			<requestURI>jms:jndi:dynamicQueues/testqueue0101</requestURI>
+			<messageBody></messageBody>
+		</responseMessage>
+	</testCase>
+
+	<testCase id="test0003" mep="inonly">
+		<address>jms:jndi:dynamicQueues/testqueue0003?jndiInitialContextFactory=org.apache.activemq.jndi.ActiveMQInitialContextFactory&amp;jndiConnectionFactoryName=ConnectionFactory&amp;jndiURL=tcp://localhost:61500</address>
+		<requestMessage>
+			<messageType>text</messageType>
+			<deliveryMode>2</deliveryMode>
+			<priority>4</priority>
+			<expiration>0</expiration>
+			<replyTo></replyTo>
+			<correlationID></correlationID>
+			<destination>queue://testqueue0003</destination>
+			<redelivered>false</redelivered>
+			<bindingVersion>1.0</bindingVersion>
+			<targetService></targetService>
+			<contentType>text/xml; charset=UTF-8</contentType>
+			<soapAction></soapAction>
+			<requestURI>jms:jndi:dynamicQueues/testqueue0003
+			</requestURI>
+			<messageBody></messageBody>
+		</requestMessage>
+	</testCase>
+	
+	<testCase id="test0004" mep="inout">
+		<address>jms:jndi:dynamicQueues/testqueue0003?jndiInitialContextFactory=org.apache.activemq.jndi.ActiveMQInitialContextFactory&amp;jndiConnectionFactoryName=ConnectionFactory&amp;jndiURL=tcp://localhost:61500</address>
+		<requestMessage>
+			<messageType>text</messageType>
+			<deliveryMode>2</deliveryMode>
+			<priority>4</priority>
+			<expiration>0</expiration>
+			<replyTo></replyTo>
+			<correlationID></correlationID>
+			<destination>queue://testqueue0003</destination>
+			<redelivered>false</redelivered>
+			<bindingVersion>1.0</bindingVersion>
+			<targetService></targetService>
+			<contentType>text/xml; charset=UTF-8</contentType>
+			<soapAction></soapAction>
+			<requestURI>jms:jndi:dynamicQueues/testqueue0003
+			</requestURI>
+			<messageBody></messageBody>
+		</requestMessage>
+		<responseMessage>
+			<messageType>text</messageType>
+			<deliveryMode>2</deliveryMode>
+			<priority>4</priority>
+			<expiration>0</expiration>
+			<replyTo></replyTo>
+			<correlationID></correlationID>
+			<destination></destination>
+			<redelivered>false</redelivered>
+			<bindingVersion>1.0</bindingVersion>
+			<targetService></targetService>
+			<contentType>text/xml; charset=UTF-8</contentType>
+			<soapAction></soapAction>
+			<requestURI>jms:jndi:dynamicQueues/testqueue0003</requestURI>
+			<messageBody></messageBody>
+		</responseMessage>
+	</testCase>
+	
+	<testCase id="test0005" mep="inout">
+		<address>jms:jndi:dynamicQueues/testqueue0005?jndiInitialContextFactory=org.apache.activemq.jndi.ActiveMQInitialContextFactory&amp;jndiConnectionFactoryName=ConnectionFactory&amp;jndiURL=tcp://localhost:61500&amp;targetService=EchoPort&amp;deliveryMode=NON_PERSISTENT&amp;timeToLive=3600000&amp;priority=5&amp;replyToName=dynamicQueues/replyqueue0005</address>
+		<requestMessage>
+			<deliveryMode>1</deliveryMode>
+			<priority>5</priority>
+			<expiration>0</expiration>
+			<replyTo>queue://replyqueue0005</replyTo>
+			<destination>queue://testqueue0005</destination>
+		</requestMessage>
+		<responseMessage>
+			<destination>queue://replyqueue0005</destination>
+		</responseMessage>
+	</testCase>
+	
+	<testCase id="test0006" mep="inout">
+		<address>jms:jndi:dynamicQueues/testqueue0006?jndiInitialContextFactory=org.apache.activemq.jndi.ActiveMQInitialContextFactory&amp;jndiConnectionFactoryName=ConnectionFactory&amp;jndiURL=tcp://localhost:61500</address>
+		<requestMessage>
+			<deliveryMode>1</deliveryMode>
+			<priority>6</priority>
+			<expiration>0</expiration>
+			<replyTo>queue://replyqueue0006</replyTo>
+			<destination>queue://testqueue0006</destination>
+		</requestMessage>
+		<responseMessage>
+			<destination>queue://replyqueue0006</destination>
+		</responseMessage>
+	</testCase>
+	
+	<testCase id="test0008" mep="inout">
+		<address>jms:jndi:dynamicQueues/testqueue0008?jndiInitialContextFactory=org.apache.activemq.jndi.ActiveMQInitialContextFactory&amp;jndiConnectionFactoryName=ConnectionFactory&amp;jndiURL=tcp://localhost:61500</address>
+		<requestMessage>
+			<deliveryMode>1</deliveryMode>
+			<priority>8</priority>
+			<expiration>0</expiration>
+			<replyTo>queue://replyqueue0008</replyTo>
+			<destination>queue://testqueue0008</destination>
+		</requestMessage>
+		<responseMessage>
+			<destination>queue://replyqueue0008</destination>
+		</responseMessage>
+	</testCase>
+	
+	<testCase id="test0009" mep="inout">
+		<address>jms:jndi:dynamicQueues/testqueue0009?jndiInitialContextFactory=org.apache.activemq.jndi.ActiveMQInitialContextFactory&amp;jndiConnectionFactoryName=ConnectionFactory&amp;jndiURL=tcp://localhost:61500&amp;targetService=EchoPort&amp;deliveryMode=PERSISTENT&amp;timeToLive=3600000&amp;priority=1&amp;replyToName=dynamicQueues/replyqueue00091</address>
+		<requestMessage>
+			<deliveryMode>1</deliveryMode>
+			<priority>3</priority>
+			<expiration>0</expiration>
+			<replyTo>queue://replyqueue00093</replyTo>
+			<destination>queue://testqueue0009</destination>
+		</requestMessage>
+		<responseMessage>
+			<destination>queue://replyqueue00093</destination>
+		</responseMessage>
+	</testCase>
+	
+	<testCase id="test0010" mep="inout">
+		<address>jms:jndi:dynamicQueues/testqueue0010?jndiInitialContextFactory=org.apache.activemq.jndi.ActiveMQInitialContextFactory&amp;jndiConnectionFactoryName=ConnectionFactory&amp;jndiURL=tcp://localhost:61500&amp;deliveryMode=PERSISTENT&amp;timeToLive=3600000&amp;priority=1&amp;replyToName=dynamicQueues/replyqueue00101</address>
+		<requestMessage>
+			<deliveryMode>2</deliveryMode>
+			<priority>1</priority>
+			<expiration>0</expiration>
+			<replyTo>queue://replyqueue00101</replyTo>
+			<destination>queue://testqueue0010</destination>
+		</requestMessage>
+		<responseMessage>
+			<destination>queue://replyqueue00101</destination>
+		</responseMessage>
+	</testCase>
+	
+	<testCase id="test0011" mep="inout">
+		<address>jms:jndi:dynamicQueues/testqueue0011?jndiInitialContextFactory=org.apache.activemq.jndi.ActiveMQInitialContextFactory&amp;jndiConnectionFactoryName=ConnectionFactory&amp;jndiURL=tcp://localhost:61500&amp;deliveryMode=PERSISTENT&amp;timeToLive=3600000&amp;priority=1&amp;replyToName=dynamicQueues/replyqueue00111&amp;deliveryMode=NON_PERSISTENT&amp;timeToLive=7200000&amp;priority=2&amp;replyToName=dynamicQueues/replyqueue00112</address>
+		<requestMessage>
+			<deliveryMode>1</deliveryMode>
+			<priority>2</priority>
+			<expiration>0</expiration>
+			<replyTo>queue://replyqueue00112</replyTo>
+			<destination>queue://testqueue0011</destination>
+		</requestMessage>
+		<responseMessage>
+			<destination>queue://replyqueue00112</destination>
+		</responseMessage>
+	</testCase>
+	
+	<testCase id="test0012" mep="inout">
+		<address>jms:jndi:dynamicQueues/testqueue0012?jndiInitialContextFactory=org.apache.activemq.jndi.ActiveMQInitialContextFactory&amp;jndiConnectionFactoryName=ConnectionFactory&amp;jndiURL=tcp://localhost:61500</address>
+		<requestMessage>
+			<deliveryMode>2</deliveryMode>
+			<priority>4</priority>
+			<expiration>0</expiration>
+			<destination>queue://testqueue0001</destination>
+		</requestMessage>
+		<responseMessage>
+			<destination>queue://replyqueue0001</destination>
+		</responseMessage>
+	</testCase>
+	
+	<testCase id="test0013" mep="inout">
+		<address>jms:jndi:dynamicQueues/testqueue0013?jndiInitialContextFactory=org.apache.activemq.jndi.ActiveMQInitialContextFactory&amp;jndiConnectionFactoryName=ConnectionFactory&amp;jndiURL=tcp://localhost:61500</address>
+		<requestMessage>
+			<deliveryMode>2</deliveryMode>
+			<priority>5</priority>
+			<expiration>360000</expiration>
+			<destination>queue://testqueue0013</destination>
+		</requestMessage>
+		<responseMessage>
+			<destination>queue://replyqueue0013</destination>
+		</responseMessage>
+	</testCase>
+	
+	<testCase id="test0014" mep="inout">
+		<address>jms:jndi:dynamicQueues/testqueue0014?jndiInitialContextFactory=org.apache.activemq.jndi.ActiveMQInitialContextFactory&amp;jndiConnectionFactoryName=ConnectionFactory&amp;jndiURL=tcp://localhost:61500</address>
+		<requestMessage>
+			<deliveryMode>2</deliveryMode>
+			<priority>5</priority>
+			<expiration>360000</expiration>
+			<destination>queue://testqueue0014</destination>
+		</requestMessage>
+		<responseMessage>
+			<destination>queue://replyqueue0014</destination>
+		</responseMessage>
+	</testCase>
+	
+	<testCase id="test1001" mep="inout">
+		<address>jms:jndi:dynamicQueues/testqueue1001?jndiInitialContextFactory=org.apache.activemq.jndi.ActiveMQInitialContextFactory&amp;jndiConnectionFactoryName=ConnectionFactory&amp;jndiURL=tcp://localhost:61500</address>
+		<requestMessage>
+			<messageType>byte</messageType>
+			<deliveryMode>2</deliveryMode>
+			<priority>4</priority>
+			<expiration>0</expiration>
+			<replyTo></replyTo>
+			<correlationID></correlationID>
+			<destination>queue://testqueue1001</destination>
+			<redelivered>false</redelivered>
+			<bindingVersion>0.3</bindingVersion>
+			<targetService></targetService>
+			<contentType>text/xml; charset=UTF-8</contentType>
+			<soapAction></soapAction>
+			<requestURI>jms:jndi:dynamicQueues/testqueue1001
+			</requestURI>
+			<messageBody></messageBody>
+		</requestMessage>
+		<responseMessage>
+			<messageType>byte</messageType>
+			<deliveryMode>2</deliveryMode>
+			<priority>4</priority>
+			<expiration>0</expiration>
+			<replyTo></replyTo>
+			<correlationID></correlationID>
+			<destination></destination>
+			<redelivered>false</redelivered>
+			<bindingVersion>1.0</bindingVersion>
+			<targetService></targetService>
+			<contentType>text/xml; charset=UTF-8</contentType>
+			<soapAction></soapAction>
+			<requestURI>jms:jndi:dynamicQueues/testqueue1001</requestURI>
+			<isFault>true</isFault>
+			<messageBody></messageBody>
+		</responseMessage>
+	</testCase>
+	
+	<testCase id="test1002" mep="inout">
+		<address>jms:jndi:dynamicQueues/testqueue1002?jndiInitialContextFactory=org.apache.activemq.jndi.ActiveMQInitialContextFactory&amp;jndiConnectionFactoryName=ConnectionFactory&amp;jndiURL=tcp://localhost:61500</address>
+		<requestMessage>
+			<messageType>stream</messageType>
+			<deliveryMode>2</deliveryMode>
+			<priority>4</priority>
+			<expiration>0</expiration>
+			<replyTo></replyTo>
+			<correlationID></correlationID>
+			<destination>queue://testqueue1002</destination>
+			<redelivered>false</redelivered>
+			<bindingVersion>1.0</bindingVersion>
+			<targetService></targetService>
+			<contentType>text/xml; charset=UTF-8</contentType>
+			<soapAction></soapAction>
+			<requestURI>jms:jndi:dynamicQueues/testqueue1002
+			</requestURI>
+			<messageBody></messageBody>
+		</requestMessage>
+		<responseMessage>
+			<messageType>byte</messageType>
+			<deliveryMode>2</deliveryMode>
+			<priority>4</priority>
+			<expiration>0</expiration>
+			<replyTo></replyTo>
+			<correlationID></correlationID>
+			<destination></destination>
+			<redelivered>false</redelivered>
+			<bindingVersion>1.0</bindingVersion>
+			<targetService></targetService>
+			<contentType>text/xml; charset=UTF-8</contentType>
+			<soapAction></soapAction>
+			<requestURI>jms:jndi:dynamicQueues/testqueue1002</requestURI>
+			<isFault>true</isFault>
+			<messageBody></messageBody>
+		</responseMessage>
+	</testCase>
+	
+	<testCase id="test1003" mep="inout">
+		<address>jms:jndi:dynamicQueues/testqueue1003?jndiInitialContextFactory=org.apache.activemq.jndi.ActiveMQInitialContextFactory&amp;jndiConnectionFactoryName=ConnectionFactory&amp;jndiURL=tcp://localhost:61500</address>
+		<requestMessage>
+			<messageType>text</messageType>
+			<deliveryMode>2</deliveryMode>
+			<priority>4</priority>
+			<expiration>0</expiration>
+			<replyTo></replyTo>
+			<correlationID></correlationID>
+			<destination>queue://testqueue1003</destination>
+			<redelivered>false</redelivered>
+			<bindingVersion>1.0</bindingVersion>
+			<targetService></targetService>
+			<contentType>text/plain; charset=UTF-8</contentType>
+			<soapAction></soapAction>
+			<requestURI>jms:jndi:dynamicQueues/testqueue1003
+			</requestURI>
+			<messageBody></messageBody>
+		</requestMessage>
+		<responseMessage>
+			<messageType>text</messageType>
+			<deliveryMode>2</deliveryMode>
+			<priority>4</priority>
+			<expiration>0</expiration>
+			<replyTo></replyTo>
+			<correlationID></correlationID>
+			<destination></destination>
+			<redelivered>false</redelivered>
+			<bindingVersion>1.0</bindingVersion>
+			<targetService></targetService>
+			<contentType>text/xml; charset=UTF-8</contentType>
+			<soapAction></soapAction>
+			<requestURI>jms:jndi:dynamicQueues/testqueue1003</requestURI>
+			<isFault>true</isFault>
+			<messageBody></messageBody>
+		</responseMessage>
+	</testCase>
+	
+	<testCase id="test1004" mep="inout">
+		<address>jms:jndi:dynamicQueues/testqueue1004?jndiInitialContextFactory=org.apache.activemq.jndi.ActiveMQInitialContextFactory&amp;jndiConnectionFactoryName=ConnectionFactory&amp;jndiURL=tcp://localhost:61500</address>
+		<requestMessage>
+			<messageType>text</messageType>
+			<deliveryMode>2</deliveryMode>
+			<priority>4</priority>
+			<expiration>0</expiration>
+			<replyTo></replyTo>
+			<correlationID></correlationID>
+			<destination>queue://testqueue1004</destination>
+			<redelivered>false</redelivered>
+			<bindingVersion>1.0</bindingVersion>
+			<targetService></targetService>
+			<contentType>text/xml; charset=UTF-8</contentType>
+			<soapAction></soapAction>
+			<requestURI>jms:domain:dynamicQueues/testqueue1004
+			</requestURI>
+			<messageBody></messageBody>
+		</requestMessage>
+		<responseMessage>
+			<messageType>text</messageType>
+			<deliveryMode>2</deliveryMode>
+			<priority>4</priority>
+			<expiration>0</expiration>
+			<replyTo></replyTo>
+			<correlationID></correlationID>
+			<destination></destination>
+			<redelivered>false</redelivered>
+			<bindingVersion>1.0</bindingVersion>
+			<targetService></targetService>
+			<contentType>text/xml; charset=UTF-8</contentType>
+			<soapAction></soapAction>
+			<requestURI>jms:domain:dynamicQueues/testqueue1004</requestURI>
+			<isFault>true</isFault>
+			<messageBody></messageBody>
+		</responseMessage>
+	</testCase>
+	
+	<testCase id="test1006" mep="inout">
+		<address>jms:jndi:dynamicQueues/testqueue1006?jndiInitialContextFactory=org.apache.activemq.jndi.ActiveMQInitialContextFactory&amp;jndiConnectionFactoryName=ConnectionFactory&amp;jndiURL=tcp://localhost:61500</address>
+		<requestMessage>
+			<messageType>text</messageType>
+			<deliveryMode>2</deliveryMode>
+			<priority>4</priority>
+			<expiration>0</expiration>
+			<replyTo></replyTo>
+			<correlationID></correlationID>
+			<destination>queue://testqueue1006</destination>
+			<redelivered>false</redelivered>
+			<bindingVersion>1.0</bindingVersion>
+			<targetService></targetService>
+			<contentType></contentType>
+			<soapAction></soapAction>
+			<requestURI>jms:jndi:dynamicQueues/testqueue1006
+			</requestURI>
+			<messageBody></messageBody>
+		</requestMessage>
+		<responseMessage>
+			<messageType>text</messageType>
+			<deliveryMode>2</deliveryMode>
+			<priority>4</priority>
+			<expiration>0</expiration>
+			<replyTo></replyTo>
+			<correlationID></correlationID>
+			<destination></destination>
+			<redelivered>false</redelivered>
+			<bindingVersion>1.0</bindingVersion>
+			<targetService></targetService>
+			<contentType>text/xml; charset=UTF-8</contentType>
+			<soapAction></soapAction>
+			<requestURI>jms:jndi:dynamicQueues/testqueue1006</requestURI>
+			<isFault>true</isFault>
+			<messageBody></messageBody>
+		</responseMessage>
+	</testCase>
+	
+	<testCase id="test1007" mep="inout">
+		<address>jms:jndi:dynamicQueues/testqueue1007?jndiInitialContextFactory=org.apache.activemq.jndi.ActiveMQInitialContextFactory&amp;jndiConnectionFactoryName=ConnectionFactory&amp;jndiURL=tcp://localhost:61500</address>
+		<requestMessage>
+			<messageType>text</messageType>
+			<deliveryMode>2</deliveryMode>
+			<priority>4</priority>
+			<expiration>0</expiration>
+			<replyTo></replyTo>
+			<correlationID></correlationID>
+			<destination>queue://testqueue1007</destination>
+			<redelivered>false</redelivered>
+			<bindingVersion>1.0</bindingVersion>
+			<targetService></targetService>
+			<contentType>text/xml; charset=UTF-8</contentType>
+			<soapAction></soapAction>
+			<requestURI></requestURI>
+			<messageBody></messageBody>
+		</requestMessage>
+		<responseMessage>
+			<messageType>text</messageType>
+			<deliveryMode>2</deliveryMode>
+			<priority>4</priority>
+			<expiration>0</expiration>
+			<replyTo></replyTo>
+			<correlationID></correlationID>
+			<destination></destination>
+			<redelivered>false</redelivered>
+			<bindingVersion>1.0</bindingVersion>
+			<targetService></targetService>
+			<contentType>text/xml; charset=UTF-8</contentType>
+			<soapAction></soapAction>
+			<requestURI></requestURI>
+			<isFault>true</isFault>
+			<messageBody></messageBody>
+		</responseMessage>
+	</testCase>
+	
+	<testCase id="test1008" mep="inout">
+		<address>jms:jndi:dynamicQueues/testqueue1008?jndiInitialContextFactory=org.apache.activemq.jndi.ActiveMQInitialContextFactory&amp;jndiConnectionFactoryName=ConnectionFactory&amp;jndiURL=tcp://localhost:61500</address>
+		<requestMessage>
+			<messageType>text</messageType>
+			<deliveryMode>2</deliveryMode>
+			<priority>4</priority>
+			<expiration>0</expiration>
+			<replyTo></replyTo>
+			<correlationID></correlationID>
+			<destination>queue://testqueue1008</destination>
+			<redelivered>false</redelivered>
+			<bindingVersion>1.0</bindingVersion>
+			<targetService></targetService>
+			<contentType>text/xml; charset=UTF-8</contentType>
+			<soapAction></soapAction>
+			<requestURI>jms:jndi:dynamicQueues/testqueue1008?targetService=EchoPort
+			</requestURI>
+			<messageBody></messageBody>
+		</requestMessage>
+		<responseMessage>
+			<messageType>text</messageType>
+			<deliveryMode>2</deliveryMode>
+			<priority>4</priority>
+			<expiration>0</expiration>
+			<replyTo></replyTo>
+			<correlationID></correlationID>
+			<destination></destination>
+			<redelivered>false</redelivered>
+			<bindingVersion>1.0</bindingVersion>
+			<targetService></targetService>
+			<contentType>text/xml; charset=UTF-8</contentType>
+			<soapAction></soapAction>
+			<requestURI></requestURI>
+			<isFault>true</isFault>
+			<messageBody></messageBody>
+		</responseMessage>
+	</testCase>
+	
+	<testCase id="test1009" mep="inout">
+		<address>jms:XXXX:dynamicQueues/testqueue1009?jndiInitialContextFactory=org.apache.activemq.jndi.ActiveMQInitialContextFactory&amp;jndiConnectionFactoryName=ConnectionFactory&amp;jndiURL=tcp://localhost:61500</address>
+		<requestMessage>
+			<messageType>text</messageType>
+			<deliveryMode>2</deliveryMode>
+			<priority>4</priority>
+			<expiration>0</expiration>
+			<replyTo></replyTo>
+			<correlationID></correlationID>
+			<destination>queue://testqueue1009</destination>
+			<redelivered>false</redelivered>
+			<bindingVersion>1.0</bindingVersion>
+			<targetService></targetService>
+			<contentType>text/xml; charset=UTF-8</contentType>
+			<soapAction></soapAction>
+			<requestURI>jms:XXXX:dynamicQueues/testqueue1009?targetService=EchoPort
+			</requestURI>
+			<messageBody></messageBody>
+		</requestMessage>
+		<responseMessage>
+			<messageType>text</messageType>
+			<deliveryMode>2</deliveryMode>
+			<priority>4</priority>
+			<expiration>0</expiration>
+			<replyTo></replyTo>
+			<correlationID></correlationID>
+			<destination></destination>
+			<redelivered>false</redelivered>
+			<bindingVersion>1.0</bindingVersion>
+			<targetService></targetService>
+			<contentType>text/xml; charset=UTF-8</contentType>
+			<soapAction></soapAction>
+			<requestURI></requestURI>
+			<isFault>true</isFault>
+			<messageBody></messageBody>
+		</responseMessage>
+	</testCase>
+
+	<testCase id="test1101" mep="inout">
+		<address>jms:jndi:dynamicQueues/testqueue1101?jndiInitialContextFactory=org.apache.activemq.jndi.ActiveMQInitialContextFactory&amp;jndiConnectionFactoryName=ConnectionFactory&amp;jndiURL=tcp://localhost:61500</address>
+		<requestMessage>
+			<messageType>byte</messageType>
+			<deliveryMode>2</deliveryMode>
+			<priority>4</priority>
+			<expiration>0</expiration>
+			<replyTo></replyTo>
+			<correlationID></correlationID>
+			<destination>queue://testqueue1101</destination>
+			<redelivered>false</redelivered>
+			<bindingVersion>0.3</bindingVersion>
+			<targetService></targetService>
+			<contentType>application/soap+xml; action="echo"; charset=UTF-8</contentType>
+			<soapAction></soapAction>
+			<requestURI>jms:jndi:dynamicQueues/testqueue1101
+			</requestURI>
+			<messageBody></messageBody>
+		</requestMessage>
+		<responseMessage>
+			<messageType>byte</messageType>
+			<deliveryMode>2</deliveryMode>
+			<priority>4</priority>
+			<expiration>0</expiration>
+			<replyTo></replyTo>
+			<correlationID></correlationID>
+			<destination></destination>
+			<redelivered>false</redelivered>
+			<bindingVersion>1.0</bindingVersion>
+			<targetService></targetService>
+			<contentType>application/soap+xml; charset=UTF-8</contentType>
+			<soapAction></soapAction>
+			<requestURI>jms:jndi:dynamicQueues/testqueue1101</requestURI>
+			<isFault>true</isFault>
+			<messageBody></messageBody>
+		</responseMessage>
+	</testCase>
+	
+	<testCase id="test1102" mep="inout">
+		<address>jms:jndi:dynamicQueues/testqueue1102?jndiInitialContextFactory=org.apache.activemq.jndi.ActiveMQInitialContextFactory&amp;jndiConnectionFactoryName=ConnectionFactory&amp;jndiURL=tcp://localhost:61500</address>
+		<requestMessage>
+			<messageType>stream</messageType>
+			<deliveryMode>2</deliveryMode>
+			<priority>4</priority>
+			<expiration>0</expiration>
+			<replyTo></replyTo>
+			<correlationID></correlationID>
+			<destination>queue://testqueue1102</destination>
+			<redelivered>false</redelivered>
+			<bindingVersion>1.0</bindingVersion>
+			<targetService></targetService>
+			<contentType>application/soap+xml; charset=UTF-8</contentType>
+			<soapAction></soapAction>
+			<requestURI>jms:jndi:dynamicQueues/testqueue1102
+			</requestURI>
+			<messageBody></messageBody>
+		</requestMessage>
+		<responseMessage>
+			<messageType>byte</messageType>
+			<deliveryMode>2</deliveryMode>
+			<priority>4</priority>
+			<expiration>0</expiration>
+			<replyTo></replyTo>
+			<correlationID></correlationID>
+			<destination></destination>
+			<redelivered>false</redelivered>
+			<bindingVersion>1.0</bindingVersion>
+			<targetService></targetService>
+			<contentType>application/soap+xml; charset=UTF-8</contentType>
+			<soapAction></soapAction>
+			<requestURI>jms:jndi:dynamicQueues/testqueue1102</requestURI>
+			<isFault>true</isFault>
+			<messageBody></messageBody>
+		</responseMessage>
+	</testCase>
+	
+	<testCase id="test1103" mep="inout">
+		<address>jms:jndi:dynamicQueues/testqueue1103?jndiInitialContextFactory=org.apache.activemq.jndi.ActiveMQInitialContextFactory&amp;jndiConnectionFactoryName=ConnectionFactory&amp;jndiURL=tcp://localhost:61500</address>
+		<requestMessage>
+			<messageType>text</messageType>
+			<deliveryMode>2</deliveryMode>
+			<priority>4</priority>
+			<expiration>0</expiration>
+			<replyTo></replyTo>
+			<correlationID></correlationID>
+			<destination>queue://testqueue1103</destination>
+			<redelivered>false</redelivered>
+			<bindingVersion>1.0</bindingVersion>
+			<targetService></targetService>
+			<contentType>text/plain; charset=UTF-8</contentType>
+			<soapAction></soapAction>
+			<requestURI>jms:jndi:dynamicQueues/testqueue1103
+			</requestURI>
+			<messageBody></messageBody>
+		</requestMessage>
+		<responseMessage>
+			<messageType>text</messageType>
+			<deliveryMode>2</deliveryMode>
+			<priority>4</priority>
+			<expiration>0</expiration>
+			<replyTo></replyTo>
+			<correlationID></correlationID>
+			<destination></destination>
+			<redelivered>false</redelivered>
+			<bindingVersion>1.0</bindingVersion>
+			<targetService></targetService>
+			<contentType>application/soap+xml; charset=UTF-8</contentType>
+			<soapAction></soapAction>
+			<requestURI>jms:jndi:dynamicQueues/testqueue1103</requestURI>
+			<isFault>true</isFault>
+			<messageBody></messageBody>
+		</responseMessage>
+	</testCase>
+	
+	<testCase id="test1104" mep="inout">
+		<address>jms:jndi:dynamicQueues/testqueue1104?jndiInitialContextFactory=org.apache.activemq.jndi.ActiveMQInitialContextFactory&amp;jndiConnectionFactoryName=ConnectionFactory&amp;jndiURL=tcp://localhost:61500</address>
+		<requestMessage>
+			<messageType>text</messageType>
+			<deliveryMode>2</deliveryMode>
+			<priority>4</priority>
+			<expiration>0</expiration>
+			<replyTo></replyTo>
+			<correlationID></correlationID>
+			<destination>queue://testqueue1104</destination>
+			<redelivered>false</redelivered>
+			<bindingVersion>1.0</bindingVersion>
+			<targetService></targetService>
+			<contentType>application/soap+xml; charset=UTF-8</contentType>
+			<soapAction></soapAction>
+			<requestURI>jms:domain:dynamicQueues/testqueue1104</requestURI>
+			<messageBody></messageBody>
+		</requestMessage>
+		<responseMessage>
+			<messageType>text</messageType>
+			<deliveryMode>2</deliveryMode>
+			<priority>4</priority>
+			<expiration>0</expiration>
+			<replyTo></replyTo>
+			<correlationID></correlationID>
+			<destination></destination>
+			<redelivered>false</redelivered>
+			<bindingVersion>1.0</bindingVersion>
+			<targetService></targetService>
+			<contentType>application/soap+xml; charset=UTF-8</contentType>
+			<soapAction></soapAction>
+			<requestURI>jms:domain:dynamicQueues/testqueue1104</requestURI>
+			<isFault>true</isFault>
+			<messageBody></messageBody>
+		</responseMessage>
+	</testCase>
+	
+	<testCase id="test1105" mep="inout">
+		<address>jms:jndi:dynamicQueues/testqueue1105?jndiInitialContextFactory=org.apache.activemq.jndi.ActiveMQInitialContextFactory&amp;jndiConnectionFactoryName=ConnectionFactory&amp;jndiURL=tcp://localhost:61500</address>
+		<requestMessage>
+			<messageType>text</messageType>
+			<deliveryMode>2</deliveryMode>
+			<priority>4</priority>
+			<expiration>0</expiration>
+			<replyTo></replyTo>
+			<correlationID></correlationID>
+			<destination>queue://testqueue1105</destination>
+			<redelivered>false</redelivered>
+			<bindingVersion>1.0</bindingVersion>
+			<targetService>EchoPort</targetService>
+			<contentType>application/soap+xml; charset=UTF-8; action="echo"</contentType>
+			<soapAction>ping</soapAction>
+			<requestURI>jms:domain:dynamicQueues/testqueue1105</requestURI>
+			<messageBody></messageBody>
+		</requestMessage>
+		<responseMessage>
+			<messageType>text</messageType>
+			<deliveryMode>2</deliveryMode>
+			<priority>4</priority>
+			<expiration>0</expiration>
+			<replyTo></replyTo>
+			<correlationID></correlationID>
+			<destination></destination>
+			<redelivered>false</redelivered>
+			<bindingVersion>1.0</bindingVersion>
+			<targetService>EchoPort</targetService>
+			<contentType>application/soap+xml; charset=UTF-8</contentType>
+			<soapAction></soapAction>
+			<requestURI>jms:domain:dynamicQueues/testqueue1105</requestURI>
+			<isFault>true</isFault>
+			<messageBody></messageBody>
+		</responseMessage>
+	</testCase>
+
+	<testCase id="test1106" mep="inout">
+		<address>jms:jndi:dynamicQueues/testqueue1106?jndiInitialContextFactory=org.apache.activemq.jndi.ActiveMQInitialContextFactory&amp;jndiConnectionFactoryName=ConnectionFactory&amp;jndiURL=tcp://localhost:61500</address>
+		<requestMessage>
+			<messageType>text</messageType>
+			<deliveryMode>2</deliveryMode>
+			<priority>4</priority>
+			<expiration>0</expiration>
+			<replyTo></replyTo>
+			<correlationID></correlationID>
+			<destination>queue://testqueue1106</destination>
+			<redelivered>false</redelivered>
+			<bindingVersion>1.0</bindingVersion>
+			<targetService></targetService>
+			<contentType></contentType>
+			<soapAction></soapAction>
+			<requestURI>jms:jndi:dynamicQueues/testqueue1106
+			</requestURI>
+			<messageBody></messageBody>
+		</requestMessage>
+		<responseMessage>
+			<messageType>text</messageType>
+			<deliveryMode>2</deliveryMode>
+			<priority>4</priority>
+			<expiration>0</expiration>
+			<replyTo></replyTo>
+			<correlationID></correlationID>
+			<destination></destination>
+			<redelivered>false</redelivered>
+			<bindingVersion>1.0</bindingVersion>
+			<targetService></targetService>
+			<contentType>application/soap+xml; charset=UTF-8</contentType>
+			<soapAction></soapAction>
+			<requestURI>jms:jndi:dynamicQueues/testqueue1106</requestURI>
+			<isFault>true</isFault>
+			<messageBody></messageBody>
+		</responseMessage>
+	</testCase>
+	
+	<testCase id="test1107" mep="inout">
+		<address>jms:jndi:dynamicQueues/testqueue1107?jndiInitialContextFactory=org.apache.activemq.jndi.ActiveMQInitialContextFactory&amp;jndiConnectionFactoryName=ConnectionFactory&amp;jndiURL=tcp://localhost:61500</address>
+		<requestMessage>
+			<messageType>text</messageType>
+			<deliveryMode>2</deliveryMode>
+			<priority>4</priority>
+			<expiration>0</expiration>
+			<replyTo></replyTo>
+			<correlationID></correlationID>
+			<destination>queue://testqueue1107</destination>
+			<redelivered>false</redelivered>
+			<bindingVersion>1.0</bindingVersion>
+			<targetService></targetService>
+			<contentType>application/soap+xml; charset=UTF-8</contentType>
+			<soapAction></soapAction>
+			<requestURI></requestURI>
+			<messageBody></messageBody>
+		</requestMessage>
+		<responseMessage>
+			<messageType>text</messageType>
+			<deliveryMode>2</deliveryMode>
+			<priority>4</priority>
+			<expiration>0</expiration>
+			<replyTo></replyTo>
+			<correlationID></correlationID>
+			<destination></destination>
+			<redelivered>false</redelivered>
+			<bindingVersion>1.0</bindingVersion>
+			<targetService></targetService>
+			<contentType>application/soap+xml; charset=UTF-8</contentType>
+			<soapAction></soapAction>
+			<requestURI></requestURI>
+			<isFault>true</isFault>
+			<messageBody></messageBody>
+		</responseMessage>
+	</testCase>
+	
+	<testCase id="test1108" mep="inout">
+		<address>jms:jndi:dynamicQueues/testqueue1108?jndiInitialContextFactory=org.apache.activemq.jndi.ActiveMQInitialContextFactory&amp;jndiConnectionFactoryName=ConnectionFactory&amp;jndiURL=tcp://localhost:61500</address>
+		<requestMessage>
+			<messageType>text</messageType>
+			<deliveryMode>2</deliveryMode>
+			<priority>4</priority>
+			<expiration>0</expiration>
+			<replyTo></replyTo>
+			<correlationID></correlationID>
+			<destination>queue://testqueue1108</destination>
+			<redelivered>false</redelivered>
+			<bindingVersion>1.0</bindingVersion>
+			<targetService></targetService>
+			<contentType>application/soap+xml; charset=UTF-8</contentType>
+			<soapAction></soapAction>
+			<requestURI>jms:jndi:dynamicQueues/testqueue1108?targetService=EchoPort
+			</requestURI>
+			<messageBody></messageBody>
+		</requestMessage>
+		<responseMessage>
+			<messageType>text</messageType>
+			<deliveryMode>2</deliveryMode>
+			<priority>4</priority>
+			<expiration>0</expiration>
+			<replyTo></replyTo>
+			<correlationID></correlationID>
+			<destination></destination>
+			<redelivered>false</redelivered>
+			<bindingVersion>1.0</bindingVersion>
+			<targetService></targetService>
+			<contentType>application/soap+xml; charset=UTF-8</contentType>
+			<soapAction></soapAction>
+			<requestURI></requestURI>
+			<isFault>true</isFault>
+			<messageBody></messageBody>
+		</responseMessage>
+	</testCase>
+
+	<testCase id="test1109" mep="inout">
+		<address>jms:XXXX:dynamicQueues/testqueue1109?jndiInitialContextFactory=org.apache.activemq.jndi.ActiveMQInitialContextFactory&amp;jndiConnectionFactoryName=ConnectionFactory&amp;jndiURL=tcp://localhost:61500</address>
+		<requestMessage>
+			<messageType>text</messageType>
+			<deliveryMode>2</deliveryMode>
+			<priority>4</priority>
+			<expiration>0</expiration>
+			<replyTo></replyTo>
+			<correlationID></correlationID>
+			<destination>queue://testqueue1109</destination>
+			<redelivered>false</redelivered>
+			<bindingVersion>1.0</bindingVersion>
+			<targetService></targetService>
+			<contentType>text/xml; charset=UTF-8</contentType>
+			<soapAction></soapAction>
+			<requestURI>jms:XXXX:dynamicQueues/testqueue1109?targetService=EchoPort
+			</requestURI>
+			<messageBody></messageBody>
+		</requestMessage>
+		<responseMessage>
+			<messageType>text</messageType>
+			<deliveryMode>2</deliveryMode>
+			<priority>4</priority>
+			<expiration>0</expiration>
+			<replyTo></replyTo>
+			<correlationID></correlationID>
+			<destination></destination>
+			<redelivered>false</redelivered>
+			<bindingVersion>1.0</bindingVersion>
+			<targetService></targetService>
+			<contentType>text/xml; charset=UTF-8</contentType>
+			<soapAction></soapAction>
+			<requestURI></requestURI>
+			<isFault>true</isFault>
+			<messageBody></messageBody>
+		</responseMessage>
+	</testCase>
+</testCases>

Added: cxf/trunk/systests/transport-jms/src/test/java/org/apache/cxf/systest/jms/GreeterByteMessageImpl.java
URL: http://svn.apache.org/viewvc/cxf/trunk/systests/transport-jms/src/test/java/org/apache/cxf/systest/jms/GreeterByteMessageImpl.java?rev=1089887&view=auto
==============================================================================
--- cxf/trunk/systests/transport-jms/src/test/java/org/apache/cxf/systest/jms/GreeterByteMessageImpl.java (added)
+++ cxf/trunk/systests/transport-jms/src/test/java/org/apache/cxf/systest/jms/GreeterByteMessageImpl.java Thu Apr  7 14:11:51 2011
@@ -0,0 +1,33 @@
+/**
+ * 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 = "HWByteMsgService", 
+            portName = "HWSByteMsgPort",
+            endpointInterface = "org.apache.cxf.hello_world_jms.HelloWorldPortType",
+            targetNamespace = "http://cxf.apache.org/hello_world_jms",
+            wsdlLocation = "testutils/jms_test.wsdl")
+public class GreeterByteMessageImpl extends TwoWayJMSImplBase {    
+    
+}



Mime
View raw message