diff options
Diffstat (limited to 'java-compat/test/src/main/java/test/Ice/dispatcher/Dispatcher.java')
| -rw-r--r-- | java-compat/test/src/main/java/test/Ice/dispatcher/Dispatcher.java | 10 |
1 files changed, 5 insertions, 5 deletions
diff --git a/java-compat/test/src/main/java/test/Ice/dispatcher/Dispatcher.java b/java-compat/test/src/main/java/test/Ice/dispatcher/Dispatcher.java index dacfa1620bb..5f722525810 100644 --- a/java-compat/test/src/main/java/test/Ice/dispatcher/Dispatcher.java +++ b/java-compat/test/src/main/java/test/Ice/dispatcher/Dispatcher.java @@ -27,7 +27,7 @@ public class Dispatcher implements Runnable, Ice.Dispatcher } @Override - public void + public void run() { while(true) @@ -45,7 +45,7 @@ public class Dispatcher implements Runnable, Ice.Dispatcher { } } - + if(!_calls.isEmpty()) { call = _calls.poll(); @@ -56,7 +56,7 @@ public class Dispatcher implements Runnable, Ice.Dispatcher return; } } - + if(call != null) { try @@ -71,7 +71,7 @@ public class Dispatcher implements Runnable, Ice.Dispatcher } } } - + @Override synchronized public void dispatch(Runnable call, Ice.Connection con) @@ -104,7 +104,7 @@ public class Dispatcher implements Runnable, Ice.Dispatcher } } } - + public boolean isDispatcherThread() { |