summaryrefslogtreecommitdiff
path: root/java/src/IceInternal/RetryTask.java
diff options
context:
space:
mode:
authorMatthew Newhook <matthew@zeroc.com>2014-07-23 15:06:02 -0230
committerMatthew Newhook <matthew@zeroc.com>2014-07-23 15:06:02 -0230
commit866f9ff17391176b836f9bb49f6da40c2c938441 (patch)
tree7366963294ef3356c7b887cd89af753988c21beb /java/src/IceInternal/RetryTask.java
parentadding ACM tests for Python/Ruby/PHP (diff)
downloadice-866f9ff17391176b836f9bb49f6da40c2c938441.tar.bz2
ice-866f9ff17391176b836f9bb49f6da40c2c938441.tar.xz
ice-866f9ff17391176b836f9bb49f6da40c2c938441.zip
ICE-4234 - Update Ice to use current Java threading constructs
- Use ScheduledThreadPoolDispatcher not IceUtilInternal.Timer. - Use Ice timer in glacier2, Freeze impl. - Align C++, C# with java changes. - Database demo now supports mariadb.
Diffstat (limited to 'java/src/IceInternal/RetryTask.java')
-rw-r--r--java/src/IceInternal/RetryTask.java11
1 files changed, 9 insertions, 2 deletions
diff --git a/java/src/IceInternal/RetryTask.java b/java/src/IceInternal/RetryTask.java
index e1c44452448..6767526e9c1 100644
--- a/java/src/IceInternal/RetryTask.java
+++ b/java/src/IceInternal/RetryTask.java
@@ -9,7 +9,7 @@
package IceInternal;
-class RetryTask implements TimerTask
+class RetryTask implements Runnable
{
RetryTask(RetryQueue queue, OutgoingAsync outAsync)
{
@@ -18,7 +18,7 @@ class RetryTask implements TimerTask
}
public void
- runTimerTask()
+ run()
{
if(_queue.remove(this))
{
@@ -36,9 +36,16 @@ class RetryTask implements TimerTask
public void
destroy()
{
+ _future.cancel(false);
_outAsync.__invokeExceptionAsync(new Ice.CommunicatorDestroyedException());
}
+ public void setFuture(java.util.concurrent.Future<?> future)
+ {
+ _future = future;
+ }
+
private final RetryQueue _queue;
private final OutgoingAsync _outAsync;
+ private java.util.concurrent.Future<?> _future;
}