diff --git a/src/main/java/org/springframework/data/redis/connection/srp/SrpUtils.java b/src/main/java/org/springframework/data/redis/connection/srp/SrpUtils.java index 5f39af521..25697e47e 100644 --- a/src/main/java/org/springframework/data/redis/connection/srp/SrpUtils.java +++ b/src/main/java/org/springframework/data/redis/connection/srp/SrpUtils.java @@ -147,10 +147,10 @@ abstract class SrpUtils { return tuples; } - static Map toMap(Object[] byteArrays) { + static Map toMap(Reply[] byteArrays) { Map map = new LinkedHashMap(byteArrays.length / 2); for (int i = 0; i < byteArrays.length; i++) { - map.put((byte[]) byteArrays[i++], (byte[]) byteArrays[i]); + map.put((byte[]) byteArrays[i++].data(), (byte[]) byteArrays[i].data()); } return map; } diff --git a/src/test/java/org/springframework/data/redis/connection/AbstractConnectionIntegrationTests.java b/src/test/java/org/springframework/data/redis/connection/AbstractConnectionIntegrationTests.java index 3f1c60419..6708bb3b5 100644 --- a/src/test/java/org/springframework/data/redis/connection/AbstractConnectionIntegrationTests.java +++ b/src/test/java/org/springframework/data/redis/connection/AbstractConnectionIntegrationTests.java @@ -25,6 +25,7 @@ import static org.junit.Assert.assertTrue; import java.util.Arrays; import java.util.List; +import java.util.Map; import java.util.Properties; import java.util.UUID; import java.util.concurrent.BlockingDeque; @@ -374,4 +375,18 @@ public abstract class AbstractConnectionIntegrationTests { assertArrayEquals(value1.getBytes(), (byte[]) result.get(2)); assertArrayEquals(value2.getBytes(), (byte[]) result.get(3)); } + + @Test + public void testHashMethod() throws Exception { + String hash = getClass() + ":hashtest"; + String key1 = UUID.randomUUID().toString(); + String key2 = UUID.randomUUID().toString(); + connection.hSet(hash, key1, UUID.randomUUID().toString()); + connection.hSet(hash, key2, UUID.randomUUID().toString()); + + Map hashMap = connection.hGetAll(hash); + assertTrue(hashMap.size() >= 2); + assertTrue(hashMap.containsKey(key1)); + assertTrue(hashMap.containsKey(key2)); + } } \ No newline at end of file