diff options
Diffstat (limited to 'java/src/IceInternal/DispatchWorkItem.java')
| -rw-r--r-- | java/src/IceInternal/DispatchWorkItem.java | 14 |
1 files changed, 4 insertions, 10 deletions
diff --git a/java/src/IceInternal/DispatchWorkItem.java b/java/src/IceInternal/DispatchWorkItem.java index dd770c720a8..84a9c438453 100644 --- a/java/src/IceInternal/DispatchWorkItem.java +++ b/java/src/IceInternal/DispatchWorkItem.java @@ -17,14 +17,10 @@ package IceInternal; // abstract public class DispatchWorkItem implements ThreadPoolWorkItem, Runnable { - public DispatchWorkItem(Instance instance) - { - _instance = instance; - } - final public void execute(ThreadPoolCurrent current) { - Ice.Dispatcher dispatcher = _instance.initializationData().dispatcher; + Instance instance = current.stream.instance(); + Ice.Dispatcher dispatcher = instance.initializationData().dispatcher; if(dispatcher != null) { try @@ -33,13 +29,13 @@ abstract public class DispatchWorkItem implements ThreadPoolWorkItem, Runnable } catch(java.lang.Exception ex) { - if(_instance.initializationData().properties.getPropertyAsIntWithDefault("Ice.Warn.Dispatch", 1) > 1) + if(instance.initializationData().properties.getPropertyAsIntWithDefault("Ice.Warn.Dispatch", 1) > 1) { java.io.StringWriter sw = new java.io.StringWriter(); java.io.PrintWriter pw = new java.io.PrintWriter(sw); ex.printStackTrace(pw); pw.flush(); - _instance.initializationData().logger.warning("dispatch exception:\n" + sw.toString()); + instance.initializationData().logger.warning("dispatch exception:\n" + sw.toString()); } } } @@ -49,6 +45,4 @@ abstract public class DispatchWorkItem implements ThreadPoolWorkItem, Runnable this.run(); } } - - private Instance _instance; } |