diff --git a/pom.xml b/pom.xml index 2bd1966e8..4d3006b28 100644 --- a/pom.xml +++ b/pom.xml @@ -25,7 +25,7 @@ 1.4.20 2.11.1 6.3.0.BUILD-SNAPSHOT - 5.0.1 + 5.0.2 1.01 4.1.100.Final spring.data.redis diff --git a/src/main/java/org/springframework/data/redis/connection/jedis/JedisClusterStreamCommands.java b/src/main/java/org/springframework/data/redis/connection/jedis/JedisClusterStreamCommands.java index f9372ba9a..5362d2b9b 100644 --- a/src/main/java/org/springframework/data/redis/connection/jedis/JedisClusterStreamCommands.java +++ b/src/main/java/org/springframework/data/redis/connection/jedis/JedisClusterStreamCommands.java @@ -17,7 +17,6 @@ package org.springframework.data.redis.connection.jedis; import static org.springframework.data.redis.connection.jedis.StreamConverters.*; -import org.springframework.util.StringUtils; import redis.clients.jedis.BuilderFactory; import redis.clients.jedis.params.XAddParams; import redis.clients.jedis.params.XClaimParams; @@ -45,6 +44,7 @@ import org.springframework.data.redis.connection.stream.StreamInfo; import org.springframework.data.redis.connection.stream.StreamOffset; import org.springframework.data.redis.connection.stream.StreamReadOptions; import org.springframework.util.Assert; +import org.springframework.util.StringUtils; /** * @author Dengliming @@ -319,7 +319,7 @@ class JedisClusterStreamCommands implements RedisStreamCommands { try { - List xread = connection.getCluster().xread(xReadParams, toStreamOffsets(streams)); + List xread = connection.getCluster().xread(xReadParams, toStreamOffsets(streams)); if (xread == null) { return Collections.emptyList(); @@ -343,7 +343,7 @@ class JedisClusterStreamCommands implements RedisStreamCommands { try { - List xread = connection.getCluster().xreadGroup(JedisConverters.toBytes(consumer.getGroup()), + List xread = connection.getCluster().xreadGroup(JedisConverters.toBytes(consumer.getGroup()), JedisConverters.toBytes(consumer.getName()), xReadParams, toStreamOffsets(streams)); if (xread == null) {