From 570455a381e6620f8ddfcca448559d3fa545ba38 Mon Sep 17 00:00:00 2001 From: Benoit Foucher Date: Fri, 10 Oct 2014 12:03:07 +0200 Subject: Fixed invocation timeouts/interrupt issues, addded AsyncResult.cancel() --- java/src/IceInternal/ConnectionRequestHandler.java | 12 ++++++------ 1 file changed, 6 insertions(+), 6 deletions(-) (limited to 'java/src/IceInternal/ConnectionRequestHandler.java') diff --git a/java/src/IceInternal/ConnectionRequestHandler.java b/java/src/IceInternal/ConnectionRequestHandler.java index f7ca7bb5b29..924b633e670 100644 --- a/java/src/IceInternal/ConnectionRequestHandler.java +++ b/java/src/IceInternal/ConnectionRequestHandler.java @@ -69,17 +69,17 @@ public class ConnectionRequestHandler implements RequestHandler } @Override - public int sendAsyncRequest(OutgoingAsyncMessageCallback out) + public int sendAsyncRequest(OutgoingAsyncBase out) throws RetryException { return out.send(_connection, _compress, _response); } @Override - public boolean - asyncRequestCanceled(OutgoingAsyncMessageCallback outgoingAsync, Ice.LocalException ex) + public void + asyncRequestCanceled(OutgoingAsyncBase outgoingAsync, Ice.LocalException ex) { - return _connection.asyncRequestCanceled(outgoingAsync, ex); + _connection.asyncRequestCanceled(outgoingAsync, ex); } @Override @@ -103,8 +103,8 @@ public class ConnectionRequestHandler implements RequestHandler return _connection; } - public ConnectionRequestHandler(Reference ref, Ice.ConnectionI connection, - boolean compress) { + public ConnectionRequestHandler(Reference ref, Ice.ConnectionI connection, boolean compress) + { _reference = ref; _response = _reference.getMode() == Reference.ModeTwoway; _connection = connection; -- cgit v1.2.3