diff options
Diffstat (limited to 'java/src/IceInternal/CollocatedRequestHandler.java')
| -rw-r--r-- | java/src/IceInternal/CollocatedRequestHandler.java | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/java/src/IceInternal/CollocatedRequestHandler.java b/java/src/IceInternal/CollocatedRequestHandler.java index 13965c3c10b..245d714a64b 100644 --- a/java/src/IceInternal/CollocatedRequestHandler.java +++ b/java/src/IceInternal/CollocatedRequestHandler.java @@ -315,7 +315,7 @@ public class CollocatedRequestHandler implements RequestHandler, ResponseHandler } } - out.attachCollocatedObserver(requestId); + out.attachCollocatedObserver(_adapter, requestId); if(_reference.getInvocationTimeout() > 0) { @@ -348,7 +348,7 @@ public class CollocatedRequestHandler implements RequestHandler, ResponseHandler } } - outAsync.__attachCollocatedObserver(requestId); + outAsync.__attachCollocatedObserver(_adapter, requestId); _adapter.getThreadPool().execute(new InvokeAllAsync(outAsync, outAsync.__getOs(), requestId, 1, false)); @@ -395,7 +395,7 @@ public class CollocatedRequestHandler implements RequestHandler, ResponseHandler } } - out.attachCollocatedObserver(0); + out.attachCollocatedObserver(_adapter, 0); if(invokeNum > 0) { @@ -454,7 +454,7 @@ public class CollocatedRequestHandler implements RequestHandler, ResponseHandler } } - outAsync.__attachCollocatedObserver(0); + outAsync.__attachCollocatedObserver(_adapter, 0); if(invokeNum > 0) { |