summaryrefslogtreecommitdiff
path: root/java/src/IceInternal/RoutableReference.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/IceInternal/RoutableReference.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/IceInternal/RoutableReference.java')
-rw-r--r--java/src/IceInternal/RoutableReference.java16
1 files changed, 12 insertions, 4 deletions
diff --git a/java/src/IceInternal/RoutableReference.java b/java/src/IceInternal/RoutableReference.java
index 694975959c5..563cbb90297 100644
--- a/java/src/IceInternal/RoutableReference.java
+++ b/java/src/IceInternal/RoutableReference.java
@@ -351,9 +351,16 @@ public class RoutableReference extends Reference
properties.put(prefix + ".EndpointSelection",
_endpointSelection == Ice.EndpointSelectionType.Random ? "Random" : "Ordered");
- StringBuffer s = new StringBuffer();
- s.append(_locatorCacheTimeout);
- properties.put(prefix + ".LocatorCacheTimeout", s.toString());
+ {
+ StringBuffer s = new StringBuffer();
+ s.append(getInvocationTimeout());
+ properties.put(prefix + ".InvocationTimeout", s.toString());
+ }
+ {
+ StringBuffer s = new StringBuffer();
+ s.append(_locatorCacheTimeout);
+ properties.put(prefix + ".LocatorCacheTimeout", s.toString());
+ }
if(_routerInfo != null)
{
@@ -656,9 +663,10 @@ public class RoutableReference extends Reference
boolean prefereSecure,
Ice.EndpointSelectionType endpointSelection,
int locatorCacheTimeout,
+ int invocationTimeout,
java.util.Map<String, String> context)
{
- super(instance, communicator, identity, facet, mode, secure, protocol, encoding, context);
+ super(instance, communicator, identity, facet, mode, secure, protocol, encoding, invocationTimeout, context);
_endpoints = endpoints;
_adapterId = adapterId;
_locatorInfo = locatorInfo;