diff --git a/redisson/src/main/java/org/redisson/RedissonRemoteService.java b/redisson/src/main/java/org/redisson/RedissonRemoteService.java index bac760f29..807d0999b 100644 --- a/redisson/src/main/java/org/redisson/RedissonRemoteService.java +++ b/redisson/src/main/java/org/redisson/RedissonRemoteService.java @@ -92,7 +92,7 @@ public class RedissonRemoteService extends BaseRemoteService implements RRemoteS protected RFuture removeAsync(String requestQueueName, RequestId taskId) { return commandExecutor.evalWriteAsync(name, LongCodec.INSTANCE, RedisCommands.EVAL_BOOLEAN, "redis.call('lrem', KEYS[1], 1, ARGV[1]); " - + "redis.call('hset', KEYS[2], ARGV[1]);" + + "redis.call('hdel', KEYS[2], ARGV[1]);" + "return 1;", Arrays.asList(requestQueueName, requestQueueName + ":tasks"), taskId.toString());