Minor refactoring for HashPartitionService

3 years ago · 0812149524
1 changed files with 1 additions and 4 deletions
--- a/common/queue/src/main/java/org/thingsboard/server/queue/discovery/HashPartitionService.java
+++ b/common/queue/src/main/java/org/thingsboard/server/queue/discovery/HashPartitionService.java
@ -526,10 +526,7 @@ public class HashPartitionService implements PartitionService {
                servers = responsible;
            }

-            int hash = hashFunction.newHasher()
-                    .putLong(tenantId.getId().getMostSignificantBits())
-                    .putLong(tenantId.getId().getLeastSignificantBits())
-                    .hash().asInt();
+            int hash = hash(tenantId.getId());
            return servers.get(Math.abs((hash + partition) % servers.size()));
        } else {
            return servers.get(partition % servers.size());