Return-Path: Delivered-To: apmail-ws-sandesha-dev-archive@www.apache.org Received: (qmail 25752 invoked from network); 5 Jan 2006 06:02:42 -0000 Received: from hermes.apache.org (HELO mail.apache.org) (209.237.227.199) by minotaur.apache.org with SMTP; 5 Jan 2006 06:02:42 -0000 Received: (qmail 21686 invoked by uid 500); 5 Jan 2006 06:02:41 -0000 Delivered-To: apmail-ws-sandesha-dev-archive@ws.apache.org Received: (qmail 21646 invoked by uid 500); 5 Jan 2006 06:02:41 -0000 Mailing-List: contact sandesha-dev-help@ws.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Delivered-To: mailing list sandesha-dev@ws.apache.org Received: (qmail 21635 invoked by uid 500); 5 Jan 2006 06:02:41 -0000 Delivered-To: apmail-ws-sandesha-cvs@ws.apache.org Received: (qmail 21632 invoked by uid 99); 5 Jan 2006 06:02:41 -0000 Received: from asf.osuosl.org (HELO asf.osuosl.org) (140.211.166.49) by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 04 Jan 2006 22:02:41 -0800 X-ASF-Spam-Status: No, hits=-9.4 required=10.0 tests=ALL_TRUSTED,NO_REAL_NAME X-Spam-Check-By: apache.org Received: from [209.237.227.194] (HELO minotaur.apache.org) (209.237.227.194) by apache.org (qpsmtpd/0.29) with SMTP; Wed, 04 Jan 2006 22:02:40 -0800 Received: (qmail 25561 invoked by uid 65534); 5 Jan 2006 06:02:29 -0000 Message-ID: <20060105060229.25559.qmail@minotaur.apache.org> Content-Type: text/plain; charset="utf-8" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit Subject: svn commit: r366094 - in /webservices/sandesha/trunk/samples/src/sandesha2/samples/interop: AsyncEchoClient.java AsyncPingClient.java SyncEchoClient.java SyncPingClient.java Date: Thu, 05 Jan 2006 06:02:28 -0000 To: sandesha-cvs@ws.apache.org From: chamikara@apache.org X-Mailer: svnmailer-1.0.5 X-Virus-Checked: Checked by ClamAV on apache.org X-Spam-Rating: minotaur.apache.org 1.6.2 0/1000/N Author: chamikara Date: Wed Jan 4 22:02:11 2006 New Revision: 366094 URL: http://svn.apache.org/viewcvs?rev=366094&view=rev Log: Changes to comply with latest Axis2 Modified: webservices/sandesha/trunk/samples/src/sandesha2/samples/interop/AsyncEchoClient.java webservices/sandesha/trunk/samples/src/sandesha2/samples/interop/AsyncPingClient.java webservices/sandesha/trunk/samples/src/sandesha2/samples/interop/SyncEchoClient.java webservices/sandesha/trunk/samples/src/sandesha2/samples/interop/SyncPingClient.java Modified: webservices/sandesha/trunk/samples/src/sandesha2/samples/interop/AsyncEchoClient.java URL: http://svn.apache.org/viewcvs/webservices/sandesha/trunk/samples/src/sandesha2/samples/interop/AsyncEchoClient.java?rev=366094&r1=366093&r2=366094&view=diff ============================================================================== --- webservices/sandesha/trunk/samples/src/sandesha2/samples/interop/AsyncEchoClient.java (original) +++ webservices/sandesha/trunk/samples/src/sandesha2/samples/interop/AsyncEchoClient.java Wed Jan 4 22:02:11 2006 @@ -22,16 +22,20 @@ import org.apache.axis2.addressing.EndpointReference; import org.apache.axis2.client.Call; import org.apache.axis2.client.Options; +import org.apache.axis2.client.ServiceClient; import org.apache.axis2.client.async.AsyncResult; import org.apache.axis2.client.async.Callback; +import org.apache.axis2.context.ConfigurationContext; +import org.apache.axis2.context.ConfigurationContextFactory; import org.apache.axis2.context.MessageContextConstants; +import org.apache.axis2.description.AxisService; import org.apache.axis2.om.OMAbstractFactory; import org.apache.axis2.om.OMElement; import org.apache.axis2.om.OMFactory; import org.apache.axis2.om.OMNamespace; import org.apache.axis2.soap.SOAP12Constants; -import org.apache.sandesha2.Sandesha2ClientAPI; -import org.apache.sandesha2.Sandesha2Constants; +import org.apache.sandesha2.client.RMReport; +import org.apache.sandesha2.client.Sandesha2ClientAPI; import org.apache.sandesha2.util.SandeshaUtil; public class AsyncEchoClient { @@ -46,7 +50,7 @@ private String toEPR = "http://" + toIP + ":" + toPort + "/axis2/services/RMInteropService"; - private String acksToEPR = "http://" + ackIP + ":" + ackPort + "/axis2/services/AnonymousService/echoString"; + private String acksToEPR = "http://" + ackIP + ":" + ackPort + "/axis2/services/" + "__ANONYMOUS_SERVICE__"; private static String SANDESHA2_HOME = ""; //Change this to ur path. @@ -74,36 +78,41 @@ return; } - Call call = new Call(AXIS2_CLIENT_PATH); - call.engageModule(new QName("Sandesha2-0.9")); + ConfigurationContext configContext = new ConfigurationContextFactory().createConfigurationContextFromFileSystem(AXIS2_CLIENT_PATH); + + ServiceClient serviceClient = new ServiceClient (configContext,null); + + Options clientOptions = new Options (); - clientOptions.setProperty(Options.COPY_PROPERTIES,new Boolean (true)); - call.setClientOptions(clientOptions); + clientOptions.setProperty(Options.COPY_PROPERTIES,new Boolean (true)); + clientOptions.setTo(new EndpointReference (toEPR)); + clientOptions.setProperty(Sandesha2ClientAPI.AcksTo,acksToEPR); + clientOptions.setProperty(Sandesha2ClientAPI.SEQUENCE_KEY,"sequence1"); + //You must set the following two properties in the request-reply case. - clientOptions.setListenerTransportProtocol(Constants.TRANSPORT_HTTP); + clientOptions.setTransportInProtocol(Constants.TRANSPORT_HTTP); clientOptions.setUseSeparateListener(true); - clientOptions.setProperty(Sandesha2ClientAPI.AcksTo,acksToEPR); - clientOptions.setSoapVersionURI(SOAP12Constants.SOAP_ENVELOPE_NAMESPACE_URI); - clientOptions.setTo(new EndpointReference(toEPR)); - clientOptions.setProperty(MessageContextConstants.TRANSPORT_URL,toEPR); - clientOptions.setProperty(Sandesha2ClientAPI.SEQUENCE_KEY,"sequence1"); //Optional - clientOptions.setSoapAction("test:soap:action"); - clientOptions.setProperty(Sandesha2ClientAPI.OFFERED_SEQUENCE_ID,SandeshaUtil.getUUID()); //Optional + serviceClient.setOptions(clientOptions); + serviceClient.engageModule(new QName ("Sandesha2-0.9")); + + String offeredSequenceID = SandeshaUtil.getUUID(); + clientOptions.setProperty(Sandesha2ClientAPI.OFFERED_SEQUENCE_ID,offeredSequenceID); //Optional + Callback callback1 = new TestCallback ("Callback 1"); - call.invokeNonBlocking("echoString", getEchoOMBlock("echo1"),callback1); + serviceClient.sendReceiveNonblocking(getEchoOMBlock("echo1"),callback1); Callback callback2 = new TestCallback ("Callback 2"); - call.invokeNonBlocking("echoString", getEchoOMBlock("echo2"),callback2); + serviceClient.sendReceiveNonblocking(getEchoOMBlock("echo2"),callback2); + clientOptions.setProperty(Sandesha2ClientAPI.LAST_MESSAGE, "true"); Callback callback3 = new TestCallback ("Callback 3"); - call.invokeNonBlocking("echoString", getEchoOMBlock("echo3"),callback3); + serviceClient.sendReceiveNonblocking(getEchoOMBlock("echo3"),callback3); while (!callback3.isComplete()) { Thread.sleep(1000); } - - call.close(); + } private static OMElement getEchoOMBlock(String text) { @@ -147,7 +156,7 @@ } - public void reportError(Exception e) { + public void onError (Exception e) { // TODO Auto-generated method stub System.out.println("Error reported for test call back"); e.printStackTrace(); Modified: webservices/sandesha/trunk/samples/src/sandesha2/samples/interop/AsyncPingClient.java URL: http://svn.apache.org/viewcvs/webservices/sandesha/trunk/samples/src/sandesha2/samples/interop/AsyncPingClient.java?rev=366094&r1=366093&r2=366094&view=diff ============================================================================== --- webservices/sandesha/trunk/samples/src/sandesha2/samples/interop/AsyncPingClient.java (original) +++ webservices/sandesha/trunk/samples/src/sandesha2/samples/interop/AsyncPingClient.java Wed Jan 4 22:02:11 2006 @@ -22,12 +22,15 @@ import org.apache.axis2.addressing.EndpointReference; import org.apache.axis2.client.MessageSender; 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.description.AxisService; import org.apache.axis2.om.OMAbstractFactory; import org.apache.axis2.om.OMElement; import org.apache.axis2.om.OMFactory; import org.apache.axis2.om.OMNamespace; -import org.apache.axis2.soap.SOAP12Constants; -import org.apache.sandesha2.Sandesha2ClientAPI; +import org.apache.sandesha2.client.Sandesha2ClientAPI; public class AsyncPingClient { @@ -42,7 +45,7 @@ private String toEPR = "http://" + toIP + ":" + toPort + "/axis2/services/RMInteropService"; - private String acksToEPR = "http://" + ackIP + ":" + ackPort + "/axis2/services/AnonymousService/echoString"; + private String acksToEPR = "http://" + ackIP + ":" + ackPort + "/axis2/services/" + "__ANONYMOUS_SERVICE__"; private static String SANDESHA2_HOME = ""; //Change this to ur path. @@ -68,19 +71,26 @@ return; } - MessageSender sender = new MessageSender (AXIS2_CLIENT_PATH); + ConfigurationContext configContext = new ConfigurationContextFactory().createConfigurationContextFromFileSystem(AXIS2_CLIENT_PATH); + + ServiceClient serviceClient = new ServiceClient (configContext,null); + Options clientOptions = new Options (); + clientOptions.setProperty(Options.COPY_PROPERTIES,new Boolean (true)); - sender.setClientOptions(clientOptions); - //clientOptions.setSoapVersionURI(SOAP12Constants.SOAP_ENVELOPE_NAMESPACE_URI); + clientOptions.setTo(new EndpointReference (toEPR)); clientOptions.setProperty(Sandesha2ClientAPI.AcksTo,acksToEPR); - sender.engageModule(new QName ("Sandesha2-0.9")); - clientOptions.setTo(new EndpointReference(toEPR)); clientOptions.setProperty(Sandesha2ClientAPI.SEQUENCE_KEY,"sequence1"); - sender.send("ping",getPingOMBlock("ping1")); - sender.send("ping",getPingOMBlock("ping2")); + + serviceClient.setOptions(clientOptions); + serviceClient.engageModule(new QName ("Sandesha2-0.9")); + + serviceClient.fireAndForget(getPingOMBlock("ping1")); + serviceClient.fireAndForget(getPingOMBlock("ping2")); + clientOptions.setProperty(Sandesha2ClientAPI.LAST_MESSAGE, "true"); - sender.send("ping",getPingOMBlock("ping3")); + serviceClient.fireAndForget(getPingOMBlock("ping3")); + } private static OMElement getPingOMBlock(String text) { Modified: webservices/sandesha/trunk/samples/src/sandesha2/samples/interop/SyncEchoClient.java URL: http://svn.apache.org/viewcvs/webservices/sandesha/trunk/samples/src/sandesha2/samples/interop/SyncEchoClient.java?rev=366094&r1=366093&r2=366094&view=diff ============================================================================== --- webservices/sandesha/trunk/samples/src/sandesha2/samples/interop/SyncEchoClient.java (original) +++ webservices/sandesha/trunk/samples/src/sandesha2/samples/interop/SyncEchoClient.java Wed Jan 4 22:02:11 2006 @@ -23,16 +23,23 @@ import org.apache.axis2.addressing.EndpointReference; import org.apache.axis2.client.Call; import org.apache.axis2.client.Options; +import org.apache.axis2.client.ServiceClient; import org.apache.axis2.client.async.AsyncResult; import org.apache.axis2.client.async.Callback; +import org.apache.axis2.context.ConfigurationContext; +import org.apache.axis2.context.ConfigurationContextFactory; +import org.apache.axis2.description.AxisOperation; +import org.apache.axis2.description.AxisService; import org.apache.axis2.om.OMAbstractFactory; import org.apache.axis2.om.OMElement; import org.apache.axis2.om.OMFactory; import org.apache.axis2.om.OMNamespace; import org.apache.axis2.soap.SOAP12Constants; -import org.apache.sandesha2.Sandesha2ClientAPI; +import org.apache.sandesha2.client.Sandesha2ClientAPI; import org.apache.sandesha2.util.SandeshaUtil; +import sandesha2.samples.interop.AsyncEchoClient.TestCallback; + public class SyncEchoClient { private String toIP = "127.0.0.1"; @@ -45,7 +52,7 @@ private static String AXIS2_CLIENT_PATH = SANDESHA2_HOME + "\\target\\repos\\client\\"; //this will be available after a maven build - public static void main(String[] args) throws AxisFault { + public static void main(String[] args) throws Exception { String axisClientRepo = null; if (args!=null && args.length>0) @@ -59,33 +66,47 @@ new SyncEchoClient().run(); } - private void run () throws AxisFault { + private void run () throws Exception { if ("".equals(SANDESHA2_HOME)){ System.out.println("ERROR: Please change to your Sandesha2 installation directory."); return; } - Call call = new Call(AXIS2_CLIENT_PATH); - call.engageModule(new QName("Sandesha2-0.9")); + + ConfigurationContext configContext = new ConfigurationContextFactory().createConfigurationContextFromFileSystem(AXIS2_CLIENT_PATH); + + ServiceClient serviceClient = new ServiceClient (configContext,null); + + Options clientOptions = new Options (); - clientOptions.setProperty(Options.COPY_PROPERTIES,new Boolean (true)); - clientOptions.setSoapVersionURI(SOAP12Constants.SOAP_ENVELOPE_NAMESPACE_URI); - call.setClientOptions(clientOptions); + clientOptions.setProperty(Options.COPY_PROPERTIES,new Boolean (true)); + clientOptions.setTo(new EndpointReference (toEPR)); + clientOptions.setProperty(Sandesha2ClientAPI.SEQUENCE_KEY,"sequence1"); + //You must set the following two properties in the request-reply case. - clientOptions.setListenerTransportProtocol(Constants.TRANSPORT_HTTP); + clientOptions.setTransportInProtocol(Constants.TRANSPORT_HTTP); clientOptions.setUseSeparateListener(true); - clientOptions.setTo(new EndpointReference(toEPR)); - clientOptions.setProperty(Sandesha2ClientAPI.SEQUENCE_KEY,"sequence1"); - //clientOptions.setProperty(Sandesha2ClientAPI.OFFERED_SEQUENCE_ID,SandeshaUtil.getUUID()); + serviceClient.setOptions(clientOptions); + serviceClient.engageModule(new QName ("Sandesha2-0.9")); + + String offeredSequenceID = SandeshaUtil.getUUID(); + clientOptions.setProperty(Sandesha2ClientAPI.OFFERED_SEQUENCE_ID,offeredSequenceID); //Optional + Callback callback1 = new TestCallback ("Callback 1"); - call.invokeNonBlocking("echoString", getEchoOMBlock("echo1"),callback1); + serviceClient.sendReceiveNonblocking(getEchoOMBlock("echo1"),callback1); Callback callback2 = new TestCallback ("Callback 2"); - call.invokeNonBlocking("echoString", getEchoOMBlock("echo2"),callback2); + serviceClient.sendReceiveNonblocking(getEchoOMBlock("echo2"),callback2); + clientOptions.setProperty(Sandesha2ClientAPI.LAST_MESSAGE, "true"); Callback callback3 = new TestCallback ("Callback 3"); - call.invokeNonBlocking("echoString", getEchoOMBlock("echo3"),callback3); + serviceClient.sendReceiveNonblocking(getEchoOMBlock("echo3"),callback3); + + while (!callback3.isComplete()) { + Thread.sleep(1000); + } + } private static OMElement getEchoOMBlock(String text) { @@ -133,7 +154,7 @@ } - public void reportError(Exception e) { + public void onError(Exception e) { // TODO Auto-generated method stub System.out.println("Error reported for test call back"); } Modified: webservices/sandesha/trunk/samples/src/sandesha2/samples/interop/SyncPingClient.java URL: http://svn.apache.org/viewcvs/webservices/sandesha/trunk/samples/src/sandesha2/samples/interop/SyncPingClient.java?rev=366094&r1=366093&r2=366094&view=diff ============================================================================== --- webservices/sandesha/trunk/samples/src/sandesha2/samples/interop/SyncPingClient.java (original) +++ webservices/sandesha/trunk/samples/src/sandesha2/samples/interop/SyncPingClient.java Wed Jan 4 22:02:11 2006 @@ -20,15 +20,22 @@ import org.apache.axis2.AxisFault; import org.apache.axis2.addressing.EndpointReference; +import org.apache.axis2.client.InOnlyMEPClient; import org.apache.axis2.client.MessageSender; +import org.apache.axis2.client.OperationClient; 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.description.AxisService; +import org.apache.axis2.engine.AxisConfiguration; +import org.apache.axis2.engine.MessageReceiver; import org.apache.axis2.om.OMAbstractFactory; import org.apache.axis2.om.OMElement; import org.apache.axis2.om.OMFactory; import org.apache.axis2.om.OMNamespace; import org.apache.axis2.soap.SOAP11Constants; -import org.apache.axis2.soap.SOAP12Constants; -import org.apache.sandesha2.Sandesha2ClientAPI; +import org.apache.sandesha2.client.Sandesha2ClientAPI; public class SyncPingClient { @@ -64,25 +71,26 @@ System.out.println("ERROR: Please change to your Sandesha2 installation directory."); return; } + ConfigurationContext configContext = new ConfigurationContextFactory().createConfigurationContextFromFileSystem(AXIS2_CLIENT_PATH); - MessageSender sender = new MessageSender (AXIS2_CLIENT_PATH); - sender.engageModule(new QName ("Sandesha2-0.9")); Options clientOptions = new Options (); - sender.setClientOptions(clientOptions); + // clientOptions.setr\ + clientOptions.setProperty(Options.COPY_PROPERTIES, new Boolean (true)); + clientOptions.setTo(new EndpointReference (toEPR)); + clientOptions.setProperty(Sandesha2ClientAPI.SEQUENCE_KEY,"sequence1"); - //clientOptions.setSoapVersionURI(SOAP12Constants.SOAP_ENVELOPE_NAMESPACE_URI); + ServiceClient serviceClient = new ServiceClient (configContext,null); + //serviceClient. - clientOptions.setProperty(Options.COPY_PROPERTIES,new Boolean (true)); - clientOptions.setSoapVersionURI(SOAP11Constants.SOAP_ENVELOPE_NAMESPACE_URI); - clientOptions.setTo(new EndpointReference(toEPR)); - //clientOptions. + serviceClient.engageModule(new QName ("Sandesha2-0.9")); + serviceClient.setOptions(clientOptions); + + serviceClient.fireAndForget(getPingOMBlock("ping1")); + serviceClient.fireAndForget(getPingOMBlock("ping2")); - clientOptions.setProperty(Sandesha2ClientAPI.SEQUENCE_KEY,"sequence1"); - sender.send("ping",getPingOMBlock("ping1")); - sender.send("ping",getPingOMBlock("ping2")); clientOptions.setProperty(Sandesha2ClientAPI.LAST_MESSAGE, "true"); - sender.send("ping",getPingOMBlock("ping3")); - + serviceClient.fireAndForget(getPingOMBlock("ping3")); + } private static OMElement getPingOMBlock(String text) { --------------------------------------------------------------------- To unsubscribe, e-mail: sandesha-dev-unsubscribe@ws.apache.org For additional commands, e-mail: sandesha-dev-help@ws.apache.org