From 71aa2ea77822d95b52f558e1d2ede50a869ad478 Mon Sep 17 00:00:00 2001 From: Xin Zheng Date: Tue, 10 Dec 2024 16:37:49 +0700 Subject: [PATCH] removed unused check --- src/main/java/org/swisspush/redisques/RedisQues.java | 6 +----- 1 file changed, 1 insertion(+), 5 deletions(-) diff --git a/src/main/java/org/swisspush/redisques/RedisQues.java b/src/main/java/org/swisspush/redisques/RedisQues.java index 9d76771..8d7388a 100644 --- a/src/main/java/org/swisspush/redisques/RedisQues.java +++ b/src/main/java/org/swisspush/redisques/RedisQues.java @@ -496,12 +496,8 @@ private void registerKeepConsumerAlive() { private void handleConsumerAlive(Message msg) { final String consumerId = msg.body(); final long periodMs = configurationProvider.configuration().getRefreshPeriod() * 1000L; - if (!UUID.fromString(consumerId).toString().equals(consumerId)) { - log.warn("invalid RedisQues consumer id {}", consumerId); - return; - } - log.debug("RedisQues consumer {} keep alive renewed", consumerId); aliveConsumers.put(consumerId, currentTimeMillis() + (periodMs * 4)); + log.debug("RedisQues consumer {} keep alive renewed", consumerId); }