You are viewing a plain text version of this content. The canonical link for it is here.
Posted to axis-cvs@ws.apache.org by de...@apache.org on 2006/03/22 10:52:18 UTC

svn commit: r387813 - /webservices/axis2/trunk/java/modules/samples/src/userguide/clients/EchoNonBlockingDualClient.java

Author: deepal
Date: Wed Mar 22 01:52:16 2006
New Revision: 387813

URL: http://svn.apache.org/viewcvs?rev=387813&view=rev
Log:
-fixing sample

Modified:
    webservices/axis2/trunk/java/modules/samples/src/userguide/clients/EchoNonBlockingDualClient.java

Modified: webservices/axis2/trunk/java/modules/samples/src/userguide/clients/EchoNonBlockingDualClient.java
URL: http://svn.apache.org/viewcvs/webservices/axis2/trunk/java/modules/samples/src/userguide/clients/EchoNonBlockingDualClient.java?rev=387813&r1=387812&r2=387813&view=diff
==============================================================================
--- webservices/axis2/trunk/java/modules/samples/src/userguide/clients/EchoNonBlockingDualClient.java (original)
+++ webservices/axis2/trunk/java/modules/samples/src/userguide/clients/EchoNonBlockingDualClient.java Wed Mar 22 01:52:16 2006
@@ -40,6 +40,7 @@
     private static EndpointReference targetEPR = new EndpointReference("http://127.0.0.1:8080/axis2/services/MyService");
 
     public static void main(String[] args) {
+        ServiceClient sender = null;
         try {
             OMElement payload = ClientUtil.getEchoOMElement();
 
@@ -71,7 +72,7 @@
             };
 
             //Non-Blocking Invocation
-            ServiceClient sender = new ServiceClient();
+            sender = new ServiceClient();
             sender.engageModule(new QName(Constants.MODULE_ADDRESSING));
             sender.setOptions(options);
             sender.sendReceiveNonBlocking(payload, callback);
@@ -86,6 +87,12 @@
             axisFault.printStackTrace();
         } catch (Exception ex) {
             ex.printStackTrace();
+        } finally{
+            try {
+                sender.finalizeInvoke();
+            } catch (AxisFault axisFault) {
+                //have to ignore this
+            }
         }
 
     }