1 files changed, 4 insertions, 2 deletions
diff --git a/java/src/IceInternal/OutgoingAsync.java b/java/src/IceInternal/OutgoingAsync.java
index e1e9beee974..b2b66a3be88 100644
--- a/java/src/IceInternal/OutgoingAsync.java
+++ b/java/src/IceInternal/OutgoingAsync.java
@@ -241,8 +241,10 @@ public class OutgoingAsync extends Ice.AsyncResult implements OutgoingAsyncMessa
                     _timerTask = null;
                 }
 
-                assert _is == null;
-                _is = new IceInternal.BasicStream(_instance, IceInternal.Protocol.currentProtocolEncoding);
+                if(_is == null) // _is can already be initialized if the invocation is retried
+                {
+                    _is = new IceInternal.BasicStream(_instance, IceInternal.Protocol.currentProtocolEncoding);
+                }
                 _is.swap(is);
                 replyStatus = _is.readByte();