diff options
Diffstat (limited to 'java/src/Ice/AMI_Object_ice_flushBatchRequests.java')
| -rw-r--r-- | java/src/Ice/AMI_Object_ice_flushBatchRequests.java | 33 |
1 files changed, 9 insertions, 24 deletions
diff --git a/java/src/Ice/AMI_Object_ice_flushBatchRequests.java b/java/src/Ice/AMI_Object_ice_flushBatchRequests.java index 211f002b9d6..5093553469b 100644 --- a/java/src/Ice/AMI_Object_ice_flushBatchRequests.java +++ b/java/src/Ice/AMI_Object_ice_flushBatchRequests.java @@ -12,7 +12,7 @@ package Ice; /** * Callback object for {@link ObjectPrx#.ice_flushBatchRequests_async}. **/ -public abstract class AMI_Object_ice_flushBatchRequests extends IceInternal.BatchOutgoingAsync +public abstract class AMI_Object_ice_flushBatchRequests extends Callback_Object_ice_flushBatchRequests { /** * Indicates to the caller that a call to <code>ice_flushBatchRequests_async</code> @@ -24,31 +24,16 @@ public abstract class AMI_Object_ice_flushBatchRequests extends IceInternal.Batc **/ public abstract void ice_exception(LocalException ex); - public final boolean __invoke(Ice.ObjectPrx prx) + public final void exception(LocalException ex) { - __acquireCallback(prx); - try - { - // - // We don't automatically retry if ice_flushBatchRequests fails. Otherwise, if some batch - // requests were queued with the connection, they would be lost without being noticed. - // - Ice._ObjectDel delegate = null; - Ice.ObjectPrxHelperBase proxy = (Ice.ObjectPrxHelperBase)prx; - try - { - delegate = proxy.__getDelegate(true); - return delegate.__getRequestHandler().flushAsyncBatchRequests(this); - } - catch(Ice.LocalException ex) - { - proxy.__handleException(delegate, ex, null, -1); // Don't retry - } - } - catch(Ice.LocalException ex) + ice_exception(ex); + } + + public final void sent() + { + if(this instanceof AMISentCallback) { - __releaseCallback(ex); + ((AMISentCallback)this).ice_sent(); } - return false; } } |