1 files changed, 4 insertions, 6 deletions
diff --git a/java/src/IceInternal/RetryTask.java b/java/src/IceInternal/RetryTask.java
index 974dc998a79..b847dc69f33 100644
--- a/java/src/IceInternal/RetryTask.java
+++ b/java/src/IceInternal/RetryTask.java
@@ -36,12 +36,10 @@ class RetryTask implements Runnable, CancellationHandler
     {
         if(_queue.remove(this) && _future.cancel(false))
         {
-            //
-            // We just retry the outgoing async now rather than marking it
-            // as finished. The retry will check for the cancellation
-            // exception and terminate appropriately the request.
-            //
-            _outAsync.retry();
+            if(_outAsync.completed(ex))
+            {
+                _outAsync.invokeCompletedAsync();
+            }
         }
     }