removed unused check

swisspost · Dec 10, 2024 · 71aa2ea · 71aa2ea
1 parent 8bcd92c
commit 71aa2ea
Showing 1 changed file with 1 addition and 5 deletions.
diff --git 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<String> 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);
     }