summaryrefslogtreecommitdiff
path: root/java/src/IceInternal/ConnectRequestHandler.java
diff options
context:
space:
mode:
Diffstat (limited to 'java/src/IceInternal/ConnectRequestHandler.java')
-rw-r--r--java/src/IceInternal/ConnectRequestHandler.java8
1 files changed, 4 insertions, 4 deletions
diff --git a/java/src/IceInternal/ConnectRequestHandler.java b/java/src/IceInternal/ConnectRequestHandler.java
index 8b2f346a997..0505688cdda 100644
--- a/java/src/IceInternal/ConnectRequestHandler.java
+++ b/java/src/IceInternal/ConnectRequestHandler.java
@@ -333,7 +333,7 @@ public class ConnectRequestHandler
//
if(!_requests.isEmpty())
{
- _reference.getInstance().clientThreadPool().execute(new DispatchWorkItem()
+ _reference.getInstance().clientThreadPool().execute(new DispatchWorkItem(_connection)
{
public void
run()
@@ -487,7 +487,7 @@ public class ConnectRequestHandler
{
assert(_exception == null && !_requests.isEmpty());
_exception = ex.get();
- _reference.getInstance().clientThreadPool().execute(new DispatchWorkItem()
+ _reference.getInstance().clientThreadPool().execute(new DispatchWorkItem(_connection)
{
public void
run()
@@ -503,7 +503,7 @@ public class ConnectRequestHandler
{
assert(_exception == null && !_requests.isEmpty());
_exception = ex;
- _reference.getInstance().clientThreadPool().execute(new DispatchWorkItem()
+ _reference.getInstance().clientThreadPool().execute(new DispatchWorkItem(_connection)
{
public void
run()
@@ -517,7 +517,7 @@ public class ConnectRequestHandler
if(!sentCallbacks.isEmpty())
{
_reference.getInstance().clientThreadPool().execute(
- new DispatchWorkItem()
+ new DispatchWorkItem(_connection)
{
public void
run()