Polishing after merge #118

redis · Aug 30, 2015 · e2f619a · e2f619a
1 parent e144da0
commit e2f619a
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/src/main/java/com/lambdaworks/redis/cluster/ClusterDistributionChannelWriter.java b/src/main/java/com/lambdaworks/redis/cluster/ClusterDistributionChannelWriter.java
@@ -1,6 +1,7 @@
 package com.lambdaworks.redis.cluster;
 
 import static com.google.common.base.Preconditions.checkArgument;
+import static com.lambdaworks.redis.cluster.SlotHash.getSlot;
 
 import java.util.List;
 
@@ -81,7 +82,7 @@ public <T, C extends RedisCommand<K, V, T>> C write(C command) {
         }
 
         if (channelWriter == null && args != null && args.getFirstEncodedKey() != null) {
-            int hash = getHash(args.getEncodedKey(0));
+            int hash = getSlot(args.getFirstEncodedKey());
             ClusterConnectionProvider.Intent intent = getIntent(command.getType());
 
             RedisChannelHandler<K, V> connection = (RedisChannelHandler<K, V>) clusterConnectionProvider.getConnection(intent,