You are viewing a plain text version of this content. The canonical link for it is here.
Posted to java-dev@axis.apache.org by he...@apache.org on 2007/06/13 21:10:10 UTC
svn commit: r547002 - in
/webservices/axis2/trunk/java/modules/integration/test/org/apache/axis2/engine:
OneWayRawXMLTest.java ThirdPartyResponseRawXMLTest.java
Author: hemapani
Date: Wed Jun 13 12:10:09 2007
New Revision: 547002
URL: http://svn.apache.org/viewvc?view=rev&rev=547002
Log:
commit new Thridparty response test and edit OneWay test to use HTTP
Added:
webservices/axis2/trunk/java/modules/integration/test/org/apache/axis2/engine/ThirdPartyResponseRawXMLTest.java
Modified:
webservices/axis2/trunk/java/modules/integration/test/org/apache/axis2/engine/OneWayRawXMLTest.java
Modified: webservices/axis2/trunk/java/modules/integration/test/org/apache/axis2/engine/OneWayRawXMLTest.java
URL: http://svn.apache.org/viewvc/webservices/axis2/trunk/java/modules/integration/test/org/apache/axis2/engine/OneWayRawXMLTest.java?view=diff&rev=547002&r1=547001&r2=547002
==============================================================================
--- webservices/axis2/trunk/java/modules/integration/test/org/apache/axis2/engine/OneWayRawXMLTest.java (original)
+++ webservices/axis2/trunk/java/modules/integration/test/org/apache/axis2/engine/OneWayRawXMLTest.java Wed Jun 13 12:10:09 2007
@@ -14,35 +14,63 @@
package org.apache.axis2.engine;
+import junit.framework.Test;
+import junit.framework.TestSuite;
+
import org.apache.axiom.soap.SOAPEnvelope;
import org.apache.axis2.AxisFault;
+import org.apache.axis2.Constants;
+import org.apache.axis2.addressing.EndpointReference;
+import org.apache.axis2.client.Options;
import org.apache.axis2.client.ServiceClient;
+import org.apache.axis2.context.ConfigurationContext;
+import org.apache.axis2.context.ConfigurationContextFactory;
import org.apache.axis2.context.MessageContext;
+import org.apache.axis2.description.AxisService;
import org.apache.axis2.description.WSDL2Constants;
+import org.apache.axis2.engine.util.TestConstants;
import org.apache.axis2.integration.LocalTestCase;
import org.apache.axis2.integration.TestingUtils;
+import org.apache.axis2.integration.UtilServer;
+import org.apache.axis2.integration.UtilServerBasedTestCase;
+import org.apache.axis2.util.Utils;
-public class OneWayRawXMLTest extends LocalTestCase {
-
+public class OneWayRawXMLTest extends UtilServerBasedTestCase implements TestConstants {
+ public static Test suite() {
+ return getTestSetup(new TestSuite(OneWayRawXMLTest.class));
+ }
+
private boolean received;
+ protected AxisService service;
protected void setUp() throws Exception {
- super.setUp();
- serverConfig.addMessageReceiver(WSDL2Constants.MEP_URI_IN_ONLY, new MessageReceiver(){
- public void receive(MessageContext messageCtx) throws AxisFault {
- SOAPEnvelope envelope = messageCtx.getEnvelope();
+ service = Utils.createSimpleInOnlyService(serviceName,new MessageReceiver(){
+ public void receive(MessageContext messageCtx) throws AxisFault {
+ SOAPEnvelope envelope = messageCtx.getEnvelope();
TestingUtils.compareWithCreatedOMElement(envelope.getBody().getFirstElement());
- received = true;
- }
- });
- deployClassAsService(Echo.SERVICE_NAME, Echo.class);
+ received = true;
+ }
+ },
+ operationName);
+ UtilServer.deployService(service);
}
public void testOneWay() throws Exception {
- ServiceClient sender = getClient(Echo.SERVICE_NAME, "echoOMElementNoResponse");
+ ConfigurationContext configContext =
+ ConfigurationContextFactory.createConfigurationContextFromFileSystem(
+ Constants.TESTING_PATH + "integrationRepo/", null);
+ ServiceClient sender = new ServiceClient(configContext, null);
+ Options op = new Options();
+// op.setTo(new EndpointReference(
+// // "http://127.0.0.1:" + (UtilServer.TESTING_PORT)
+// "http://127.0.0.1:" + 5556
+// + "/axis2/services/"+service.getName()+"/"+operationName.getLocalPart()));
+ op.setTo(targetEPR);
+ op.setAction("urn:SomeAction");
+ sender.setOptions(op);
sender.fireAndForget(TestingUtils.createDummyOMElement());
int index = 0;
while (!received) {
- Thread.sleep(10);
+ Thread.sleep(1000);
index++;
if (index == 20) {
throw new AxisFault("error Occured");
Added: webservices/axis2/trunk/java/modules/integration/test/org/apache/axis2/engine/ThirdPartyResponseRawXMLTest.java
URL: http://svn.apache.org/viewvc/webservices/axis2/trunk/java/modules/integration/test/org/apache/axis2/engine/ThirdPartyResponseRawXMLTest.java?view=auto&rev=547002
==============================================================================
--- webservices/axis2/trunk/java/modules/integration/test/org/apache/axis2/engine/ThirdPartyResponseRawXMLTest.java (added)
+++ webservices/axis2/trunk/java/modules/integration/test/org/apache/axis2/engine/ThirdPartyResponseRawXMLTest.java Wed Jun 13 12:10:09 2007
@@ -0,0 +1,98 @@
+/*
+ * Licensed 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.axis2.engine;
+
+import javax.xml.namespace.QName;
+
+import junit.framework.Test;
+import junit.framework.TestSuite;
+
+import org.apache.axiom.soap.SOAPEnvelope;
+import org.apache.axis2.AxisFault;
+import org.apache.axis2.Constants;
+import org.apache.axis2.addressing.EndpointReference;
+import org.apache.axis2.client.Options;
+import org.apache.axis2.client.ServiceClient;
+import org.apache.axis2.context.ConfigurationContext;
+import org.apache.axis2.context.ConfigurationContextFactory;
+import org.apache.axis2.context.MessageContext;
+import org.apache.axis2.description.AxisService;
+import org.apache.axis2.engine.util.TestConstants;
+import org.apache.axis2.integration.TestingUtils;
+import org.apache.axis2.integration.UtilServer;
+import org.apache.axis2.integration.UtilServerBasedTestCase;
+import org.apache.axis2.transport.http.SimpleHTTPServer;
+import org.apache.axis2.util.Utils;
+
+public class ThirdPartyResponseRawXMLTest extends UtilServerBasedTestCase implements TestConstants {
+ public static Test suite() {
+ return getTestSetup(new TestSuite(ThirdPartyResponseRawXMLTest.class));
+ }
+
+ private boolean received;
+ protected AxisService service;
+ private SimpleHTTPServer receiver;
+ private String callbackOperation;
+ private String callbackServiceName = "CallbackService";
+ private int callbackserverPort = 17458;
+
+ protected void setUp() throws Exception {
+ service = Utils.createSimpleService(serviceName,
+ Echo.class.getName(),
+ operationName);
+ UtilServer.deployService(service);
+
+ callbackOperation = "callback";
+ AxisService callbackService = Utils.createSimpleInOnlyService(new QName(callbackServiceName),new MessageReceiver(){
+ public void receive(MessageContext messageCtx) throws AxisFault {
+ SOAPEnvelope envelope = messageCtx.getEnvelope();
+ TestingUtils.compareWithCreatedOMElement(envelope.getBody().getFirstElement());
+ received = true;
+ }
+ },new QName(callbackOperation));
+ UtilServer.deployService(callbackService);
+
+ receiver = new SimpleHTTPServer(UtilServer.getConfigurationContext(), callbackserverPort);
+ receiver.start();
+ }
+
+ public void testOneWay() throws Exception {
+ ConfigurationContext configContext =
+ ConfigurationContextFactory.createConfigurationContextFromFileSystem(
+ Constants.TESTING_PATH + "integrationRepo/", null);
+ ServiceClient sender = new ServiceClient(configContext, null);
+ Options op = new Options();
+ op.setTo(targetEPR);
+
+ op.setReplyTo(new EndpointReference("http://127.0.0.1:"+(callbackserverPort)+"/axis2/services/"+callbackServiceName+ "/"+callbackOperation));
+ op.setAction("urn:SomeAction");
+ sender.setOptions(op);
+ sender.engageModule(Constants.MODULE_ADDRESSING);
+ sender.fireAndForget(TestingUtils.createDummyOMElement());
+ int index = 0;
+ while (!received) {
+ Thread.sleep(1000);
+ index++;
+ if (index == 20) {
+ throw new AxisFault("error Occured");
+ }
+ }
+ }
+
+ protected void tearDown() throws Exception {
+ receiver.stop();
+ }
+
+}
---------------------------------------------------------------------
To unsubscribe, e-mail: axis-cvs-unsubscribe@ws.apache.org
For additional commands, e-mail: axis-cvs-help@ws.apache.org