1 files changed, 3 insertions, 3 deletions
diff --git a/java/src/IceInternal/IncomingConnectionFactory.java b/java/src/IceInternal/IncomingConnectionFactory.java
index 17d046cb4f0..48c7b1aea5f 100644
--- a/java/src/IceInternal/IncomingConnectionFactory.java
+++ b/java/src/IceInternal/IncomingConnectionFactory.java
@@ -149,13 +149,13 @@ public final class IncomingConnectionFactory extends EventHandler implements Ice
     }
 
     public void
-    flushBatchRequests()
+    flushAsyncBatchRequests(CommunicatorBatchOutgoingAsync outAsync)
     {
-        for(Ice.ConnectionI p : connections()) // connections() is synchronized, no need to synchronize here.
+        for(Ice.ConnectionI c : connections()) // connections() is synchronized, no need to synchronize here.
         {
             try
             {
-                p.flushBatchRequests();
+                outAsync.flushConnection(c);
             }
             catch(Ice.LocalException ex)
             {