diff options
author | Benoit Foucher <benoit@zeroc.com> | 2014-05-23 11:59:44 +0200 |
---|---|---|
committer | Benoit Foucher <benoit@zeroc.com> | 2014-05-23 11:59:44 +0200 |
commit | d81701ca8182942b7936f9fd84a019b695e9c890 (patch) | |
tree | dc036c9d701fbbe1afad67782bd78572c0f61974 /java/src/Ice/ObjectPrxHelperBase.java | |
parent | Fixed bug ICE-5543: stringToIdentity bug with escaped escapes (diff) | |
download | ice-d81701ca8182942b7936f9fd84a019b695e9c890.tar.bz2 ice-d81701ca8182942b7936f9fd84a019b695e9c890.tar.xz ice-d81701ca8182942b7936f9fd84a019b695e9c890.zip |
Added support for invocation timeouts and ACM heartbeats
Diffstat (limited to 'java/src/Ice/ObjectPrxHelperBase.java')
-rw-r--r-- | java/src/Ice/ObjectPrxHelperBase.java | 53 |
1 files changed, 41 insertions, 12 deletions
diff --git a/java/src/Ice/ObjectPrxHelperBase.java b/java/src/Ice/ObjectPrxHelperBase.java index b12b0d5dfbd..8bf9d9ec26d 100644 --- a/java/src/Ice/ObjectPrxHelperBase.java +++ b/java/src/Ice/ObjectPrxHelperBase.java @@ -297,11 +297,11 @@ public class ObjectPrxHelperBase implements ObjectPrx, java.io.Serializable IceInternal.BasicStream __os = __result.__startWriteParams(Ice.FormatType.DefaultFormat); __os.writeString(__id); __result.__endWriteParams(); - __result.__send(true); + __result.__invoke(true); } catch(LocalException __ex) { - __result.__exceptionAsync(__ex); + __result.__invokeExceptionAsync(__ex); } return __result; } @@ -573,11 +573,11 @@ public class ObjectPrxHelperBase implements ObjectPrx, java.io.Serializable { __result.__prepare(__ice_ping_name, OperationMode.Nonmutating, __context, __explicitCtx); __result.__writeEmptyParams(); - __result.__send(true); + __result.__invoke(true); } catch(LocalException __ex) { - __result.__exceptionAsync(__ex); + __result.__invokeExceptionAsync(__ex); } return __result; } @@ -841,11 +841,11 @@ public class ObjectPrxHelperBase implements ObjectPrx, java.io.Serializable { __result.__prepare(__ice_ids_name, OperationMode.Nonmutating, __context, __explicitCtx); __result.__writeEmptyParams(); - __result.__send(true); + __result.__invoke(true); } catch(LocalException __ex) { - __result.__exceptionAsync(__ex); + __result.__invokeExceptionAsync(__ex); } return __result; } @@ -1134,11 +1134,11 @@ public class ObjectPrxHelperBase implements ObjectPrx, java.io.Serializable { __result.__prepare(__ice_id_name, OperationMode.Nonmutating, __context, __explicitCtx); __result.__writeEmptyParams(); - __result.__send(true); + __result.__invoke(true); } catch(LocalException __ex) { - __result.__exceptionAsync(__ex); + __result.__invokeExceptionAsync(__ex); } return __result; } @@ -1545,11 +1545,11 @@ public class ObjectPrxHelperBase implements ObjectPrx, java.io.Serializable { __result.__prepare(operation, mode, __context, __explicitCtx); __result.__writeParamEncaps(inParams); - __result.__send(true); + __result.__invoke(true); } catch(LocalException __ex) { - __result.__exceptionAsync(__ex); + __result.__invokeExceptionAsync(__ex); } return __result; } @@ -1832,6 +1832,17 @@ public class ObjectPrxHelperBase implements ObjectPrx, java.io.Serializable } /** + * Returns the invocation timeout of this proxy. + * + * @return The invocation timeout value (in seconds). + **/ + public final int + ice_getInvocationTimeout() + { + return _reference.getInvocationTimeout(); + } + + /** * Returns the connection id of this proxy. * * @return The connection id. @@ -1864,6 +1875,24 @@ public class ObjectPrxHelperBase implements ObjectPrx, java.io.Serializable } /** + * Creates a new proxy that is identical to this proxy, except for the invocation timeout. + * + * @param newTimeout The new invocation timeout (in seconds). + **/ + public final ObjectPrx + ice_invocationTimeout(int newTimeout) + { + if(newTimeout == _reference.getInvocationTimeout()) + { + return this; + } + else + { + return newInstance(_reference.changeInvocationTimeout(newTimeout)); + } + } + + /** * Returns whether this proxy caches connections. * * @return <code>true</code> if this proxy caches connections; <code>false</code>, otherwise. @@ -2498,11 +2527,11 @@ public class ObjectPrxHelperBase implements ObjectPrx, java.io.Serializable new IceInternal.ProxyBatchOutgoingAsync(this, __ice_flushBatchRequests_name, __cb); try { - __result.__send(); + __result.__invoke(); } catch(LocalException __ex) { - __result.__exceptionAsync(__ex); + __result.__invokeExceptionAsync(__ex); } return __result; } |