Spring/spring-data-redis
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Upgrade to Jedis 5.0.2.

Browse Source 
Closes #2763
This commit is contained in:
Mark Paluch
2023-11-06 09:41:08 +01:00
parent 37ecdc544c
commit f97bd87d70
2 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
pom.xml
View File

@@ -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>

6
src/main/java/org/springframework/data/redis/connection/jedis/JedisClusterStreamCommands.java
View File

@@ -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<byte[]> 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<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) {