1 files changed, 2 insertions, 1 deletions
diff --git a/java/src/IceInternal/ProxyBatchOutgoingAsync.java b/java/src/IceInternal/ProxyBatchOutgoingAsync.java
index 21ff5b9da1c..9d325d21d44 100644
--- a/java/src/IceInternal/ProxyBatchOutgoingAsync.java
+++ b/java/src/IceInternal/ProxyBatchOutgoingAsync.java
@@ -16,6 +16,7 @@ public class ProxyBatchOutgoingAsync extends BatchOutgoingAsync
         super(prx.ice_getCommunicator(), ((Ice.ObjectPrxHelperBase)prx).__reference().getInstance(), operation,
               callback);
         _proxy = prx;
+        _observer = ObserverHelper.get(prx, operation);
     }
 
     public void __send()
@@ -41,7 +42,7 @@ public class ProxyBatchOutgoingAsync extends BatchOutgoingAsync
         }
         catch(Ice.LocalException __ex)
         {
-            cnt = ((Ice.ObjectPrxHelperBase)_proxy).__handleException(delegate, __ex, null, cnt);
+            cnt = ((Ice.ObjectPrxHelperBase)_proxy).__handleException(delegate, __ex, null, cnt, _observer);
         }
     }