From 9781ca642bb2c59794f5b84d9c7dfe0a23494ab6 Mon Sep 17 00:00:00 2001 From: Nikita Koksharov Date: Wed, 25 Dec 2024 09:30:07 +0300 Subject: [PATCH] refactoring --- .../org/redisson/executor/RedissonScheduledFuture.java | 10 +--------- 1 file changed, 1 insertion(+), 9 deletions(-) diff --git a/redisson/src/main/java/org/redisson/executor/RedissonScheduledFuture.java b/redisson/src/main/java/org/redisson/executor/RedissonScheduledFuture.java index 1f85d24d4..c98682497 100644 --- a/redisson/src/main/java/org/redisson/executor/RedissonScheduledFuture.java +++ b/redisson/src/main/java/org/redisson/executor/RedissonScheduledFuture.java @@ -16,7 +16,6 @@ package org.redisson.executor; import org.redisson.api.RScheduledFuture; -import org.redisson.misc.CompletableFutureWrapper; import java.util.concurrent.Delayed; import java.util.concurrent.TimeUnit; @@ -27,16 +26,14 @@ import java.util.concurrent.TimeUnit; * * @param value type */ -public class RedissonScheduledFuture extends CompletableFutureWrapper implements RScheduledFuture { +public class RedissonScheduledFuture extends RedissonExecutorFuture implements RScheduledFuture { private final long scheduledExecutionTime; - private final String taskId; private final RemotePromise promise; public RedissonScheduledFuture(RemotePromise promise, long scheduledExecutionTime) { super(promise); this.scheduledExecutionTime = scheduledExecutionTime; - this.taskId = promise.getRequestId(); this.promise = promise; } @@ -66,9 +63,4 @@ public class RedissonScheduledFuture extends CompletableFutureWrapper impl return unit.convert(scheduledExecutionTime - System.currentTimeMillis(), TimeUnit.MILLISECONDS); } - @Override - public String getTaskId() { - return taskId; - } - }