axis-java-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ngalla...@apache.org
Subject svn commit: r483626 - /webservices/axis2/trunk/java/modules/jaxws/src/org/apache/axis2/jaxws/client/async/AsyncResponse.java
Date Thu, 07 Dec 2006 19:29:39 GMT
Author: ngallardo
Date: Thu Dec  7 11:29:37 2006
New Revision: 483626

URL: http://svn.apache.org/viewvc?view=rev&rev=483626
Log:
AXIS2-1824

-Changed AsyncResponse to use a CountDownLatch for blocking
-Implemented get(long, TimeUnit)

Modified:
    webservices/axis2/trunk/java/modules/jaxws/src/org/apache/axis2/jaxws/client/async/AsyncResponse.java

Modified: webservices/axis2/trunk/java/modules/jaxws/src/org/apache/axis2/jaxws/client/async/AsyncResponse.java
URL: http://svn.apache.org/viewvc/webservices/axis2/trunk/java/modules/jaxws/src/org/apache/axis2/jaxws/client/async/AsyncResponse.java?view=diff&rev=483626&r1=483625&r2=483626
==============================================================================
--- webservices/axis2/trunk/java/modules/jaxws/src/org/apache/axis2/jaxws/client/async/AsyncResponse.java
(original)
+++ webservices/axis2/trunk/java/modules/jaxws/src/org/apache/axis2/jaxws/client/async/AsyncResponse.java
Thu Dec  7 11:29:37 2006
@@ -20,6 +20,7 @@
 
 import java.util.HashMap;
 import java.util.Map;
+import java.util.concurrent.CountDownLatch;
 import java.util.concurrent.ExecutionException;
 import java.util.concurrent.TimeUnit;
 import java.util.concurrent.TimeoutException;
@@ -47,21 +48,25 @@
 
     private static final Log log = LogFactory.getLog(AsyncResponse.class);
     
-    private boolean done;
     private boolean cancelled;
     private Object responseObj;
     private MessageContext response;
     private Map<String, Object> responseContext;
     private Throwable fault;
+    private CountDownLatch latch;
+    
+    protected AsyncResponse() {
+        latch = new CountDownLatch(1);
+    }
     
     protected void onError(Throwable t) {
         fault = t;
-        done = true;
+        latch.countDown();
     }
     
     protected void onComplete(MessageContext mc) {
         response = mc;
-        done = true;
+        latch.countDown();
     }
     
     //-------------------------------------
@@ -76,7 +81,7 @@
 
         // TODO: Do we actually need to do some level of interrupt on the
         // processing in the get() call?  If so, how?  
-        if (!cancelled || !done) {
+        if (!cancelled || !(latch.getCount() == 0)) {
             return false;
         }
         else {
@@ -86,6 +91,9 @@
     }
 
     public Object get() throws InterruptedException, ExecutionException {
+        // Wait for the response to come back
+        latch.await();
+        
         if (hasFault()) {
             throw new ExecutionException(fault);
         }
@@ -106,9 +114,28 @@
         return responseObj;
     }
 
-    // TODO: Implement this method with the correct timeout
     public Object get(long timeout, TimeUnit unit) throws InterruptedException, ExecutionException,
TimeoutException {
-        return null;
+        // Wait for the response to come back
+        latch.await(timeout, unit);
+        
+        if (hasFault()) {
+            throw new ExecutionException(fault);
+        }
+        if (response == null) {
+            WebServiceException wse = new WebServiceException("null response");
+            throw new ExecutionException(wse);
+        }
+        
+        // TODO: Check the type of the object to make sure it corresponds with
+        // the parameterized generic type.
+        if (responseObj == null) {
+            if (log.isDebugEnabled()) {
+                log.debug("Demarshalling the async response message");
+            }
+            responseObj = getResponseValueObject(response);
+        }
+
+        return responseObj;
     }
 
     public boolean isCancelled() {
@@ -116,7 +143,7 @@
     }
 
     public boolean isDone() {
-        return done;
+        return (latch.getCount() == 0);
     }
 
     public Map getContext() {



---------------------------------------------------------------------
To unsubscribe, e-mail: axis-cvs-unsubscribe@ws.apache.org
For additional commands, e-mail: axis-cvs-help@ws.apache.org


Mime
View raw message