diff options
Diffstat (limited to 'java/src/Ice/CommunicatorI.java')
| -rw-r--r-- | java/src/Ice/CommunicatorI.java | 10 |
1 files changed, 6 insertions, 4 deletions
diff --git a/java/src/Ice/CommunicatorI.java b/java/src/Ice/CommunicatorI.java index 76d46baab6a..fab8cf98605 100644 --- a/java/src/Ice/CommunicatorI.java +++ b/java/src/Ice/CommunicatorI.java @@ -263,8 +263,10 @@ public final class CommunicatorI implements Communicator // This callback object receives the results of all invocations // of Connection.begin_flushBatchRequests. // - IceInternal.CommunicatorBatchOutgoingAsync result = - new IceInternal.CommunicatorBatchOutgoingAsync(this, _instance, __flushBatchRequests_name, cb); + IceInternal.CommunicatorFlushBatch result = new IceInternal.CommunicatorFlushBatch(this, + _instance, + __flushBatchRequests_name, + cb); connectionFactory.flushAsyncBatchRequests(result); adapterFactory.flushAsyncBatchRequests(result); @@ -282,8 +284,8 @@ public final class CommunicatorI implements Communicator public void end_flushBatchRequests(AsyncResult r) { - IceInternal.OutgoingAsyncBase ri = (IceInternal.OutgoingAsyncBase)r; - IceInternal.OutgoingAsyncBase.check(ri, this, __flushBatchRequests_name); + IceInternal.CommunicatorFlushBatch ri = + IceInternal.CommunicatorFlushBatch.check(r, this, __flushBatchRequests_name); ri.__wait(); } |