diff --git a/src/main/java/org/springframework/data/redis/core/RedisKeyValueAdapter.java b/src/main/java/org/springframework/data/redis/core/RedisKeyValueAdapter.java index 4fd7064b80..f1a3104fe1 100644 --- a/src/main/java/org/springframework/data/redis/core/RedisKeyValueAdapter.java +++ b/src/main/java/org/springframework/data/redis/core/RedisKeyValueAdapter.java @@ -272,9 +272,7 @@ public Object get(Object id, String keyspace) { public T get(Object id, String keyspace, Class type) { String stringId = asString(id); - String stringKeyspace = asString(keyspace); - - byte[] binId = createKey(stringKeyspace, stringId); + byte[] binId = createKey(keyspace, stringId); RedisCallback> command = connection -> connection.hGetAll(binId); @@ -287,7 +285,7 @@ public T get(Object id, String keyspace, Class type) { RedisData data = new RedisData(raw); data.setId(stringId); - data.setKeyspace(stringKeyspace); + data.setKeyspace(keyspace); return readBackTimeToLiveIfSet(binId, converter.read(type, data)); } @@ -307,13 +305,13 @@ public T delete(Object id, String keyspace, Class type) { if (value != null) { - byte[] keyToDelete = createKey(asString(keyspace), asString(id)); + byte[] keyToDelete = createKey(keyspace, asString(id)); redisOps.execute((RedisCallback) connection -> { connection.del(keyToDelete); connection.sRem(binKeyspace, binId); - new IndexWriter(connection, converter).removeKeyFromIndexes(asString(keyspace), binId); + new IndexWriter(connection, converter).removeKeyFromIndexes(keyspace, binId); if (RedisKeyValueAdapter.this.keepShadowCopy()) { @@ -384,7 +382,7 @@ public void deleteAllOf(String keyspace) { redisOps.execute((RedisCallback) connection -> { connection.del(toBytes(keyspace)); - new IndexWriter(connection, converter).removeAllIndexes(asString(keyspace)); + new IndexWriter(connection, converter).removeAllIndexes(keyspace); return null; }); }