From 0af8167bd523cd7c293f892e49b75eb327e9a721 Mon Sep 17 00:00:00 2001 From: Nikita Koksharov Date: Thu, 30 Jun 2022 13:59:44 +0300 Subject: [PATCH] refactoring --- .../src/main/java/org/redisson/RedissonExecutorService.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/redisson/src/main/java/org/redisson/RedissonExecutorService.java b/redisson/src/main/java/org/redisson/RedissonExecutorService.java index 7266a02f2..a38c8147d 100644 --- a/redisson/src/main/java/org/redisson/RedissonExecutorService.java +++ b/redisson/src/main/java/org/redisson/RedissonExecutorService.java @@ -172,7 +172,7 @@ public class RedissonExecutorService implements RScheduledExecutorService { asyncScheduledServiceAtFixed = scheduledRemoteService.get(RemoteExecutorServiceAsync.class, RemoteInvocationOptions.defaults().noAck().noResult()); } - protected String generateRequestId() { + protected String generateActiveWorkersId() { byte[] id = new byte[16]; ThreadLocalRandom.current().nextBytes(id); return ByteBufUtil.hexDump(id); @@ -210,7 +210,7 @@ public class RedissonExecutorService implements RScheduledExecutorService { @Override public int countActiveWorkers() { - String id = generateRequestId(); + String id = generateActiveWorkersId(); int subscribers = (int) workersTopic.publish(id); if (subscribers == 0) { return 0;