summaryrefslogtreecommitdiff
path: root/java/src/Ice/ObjectPrxHelperBase.java
diff options
context:
space:
mode:
authorBenoit Foucher <benoit@zeroc.com>2014-05-23 11:59:44 +0200
committerBenoit Foucher <benoit@zeroc.com>2014-05-23 11:59:44 +0200
commitd81701ca8182942b7936f9fd84a019b695e9c890 (patch)
treedc036c9d701fbbe1afad67782bd78572c0f61974 /java/src/Ice/ObjectPrxHelperBase.java
parentFixed bug ICE-5543: stringToIdentity bug with escaped escapes (diff)
downloadice-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.java53
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;
}