Skip to content

Commit

Permalink
Upgrade to Jedis 5.0.2.
Browse files Browse the repository at this point in the history
Closes #2763
  • Loading branch information
mp911de committed Nov 6, 2023
1 parent 37ecdc5 commit f97bd87
Show file tree
Hide file tree
Showing 2 changed files with 4 additions and 4 deletions.
2 changes: 1 addition & 1 deletion pom.xml
Original file line number Diff line number Diff line change
Expand Up @@ -25,7 +25,7 @@
<xstream>1.4.20</xstream>
<pool>2.11.1</pool>
<lettuce>6.3.0.BUILD-SNAPSHOT</lettuce>
<jedis>5.0.1</jedis>
<jedis>5.0.2</jedis>
<multithreadedtc>1.01</multithreadedtc>
<netty>4.1.100.Final</netty>
<java-module-name>spring.data.redis</java-module-name>
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -17,7 +17,6 @@

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;
Expand Down Expand Up @@ -45,6 +44,7 @@
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
Expand Down Expand Up @@ -319,7 +319,7 @@ public List<ByteRecord> xRead(StreamReadOptions readOptions, StreamOffset<byte[]

try {

List<byte[]> xread = connection.getCluster().xread(xReadParams, toStreamOffsets(streams));
List<?> xread = connection.getCluster().xread(xReadParams, toStreamOffsets(streams));

if (xread == null) {
return Collections.emptyList();
Expand All @@ -343,7 +343,7 @@ public List<ByteRecord> xReadGroup(Consumer consumer, StreamReadOptions readOpti

try {

List<byte[]> 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) {
Expand Down

0 comments on commit f97bd87

Please sign in to comment.