1 files changed, 19 insertions, 7 deletions
diff --git a/java/src/IceInternal/BatchOutgoingAsync.java b/java/src/IceInternal/BatchOutgoingAsync.java
index 4564fde7d3f..4ac4aa396da 100644
--- a/java/src/IceInternal/BatchOutgoingAsync.java
+++ b/java/src/IceInternal/BatchOutgoingAsync.java
@@ -9,18 +9,30 @@
 
 package IceInternal;
 
-public abstract class BatchOutgoingAsync extends OutgoingAsyncMessageCallback
+public class BatchOutgoingAsync extends Ice.AsyncResult implements OutgoingAsyncMessageCallback
 {
-    public final void
-    __sent(final Ice.ConnectionI connection)
+    public BatchOutgoingAsync(Instance instance, String operation, CallbackBase callback)
     {
-        __releaseCallback();
+        super(instance, operation, callback);
+    }
+
+    public boolean __sent(Ice.ConnectionI connection)
+    {
+        synchronized(_monitor)
+        {
+            _state |= Done | OK | Sent;
+            _monitor.notifyAll();
+            return true;
+        }
+    }
+
+    public void __sent()
+    {
+        __sentInternal();
     }
     
-    public final void
-    __finished(Ice.LocalException exc)
+    public void __finished(Ice.LocalException exc, boolean sent)
     {
         __exception(exc);
     }
-
 }