feat(impv): Support Jedis

Author: whatasame

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

@@ -48,6 +48,7 @@
 
 /**
  * @author Dengliming
+ * @author Jeonggyu Choi
  * @since 2.3
  */
 class JedisClusterStreamCommands implements RedisStreamCommands {
@@ -283,6 +284,10 @@ public PendingMessages xPending(byte[] key, String groupName, XPendingOptions op
 				pendingParams = pendingParams.consumer(consumerName);
 			}
 
+			if (options.hasIdle()) {
+				pendingParams = pendingParams.idle(options.getIdleMillis());
+			}
+
 			List<Object> response = connection.getCluster().xpending(key, group, pendingParams);
 
 			return StreamConverters.toPendingMessages(groupName, range,

src/main/java/org/springframework/data/redis/connection/jedis/StreamConverters.java

@@ -55,6 +55,7 @@
  *
  * @author dengliming
  * @author Mark Paluch
+ * @author Jeonggyu Choi
  * @since 2.3
  */
 class StreamConverters {
@@ -306,6 +307,9 @@ public static XPendingParams toXPendingParams(RedisStreamCommands.XPendingOption
 		if (options.hasConsumer()) {
 			xPendingParams.consumer(options.getConsumerName());
 		}
+		if (options.hasIdle()) {
+			xPendingParams.idle(options.getIdleMillis());
+		}
 
 		return xPendingParams;
 	}

src/test/java/org/springframework/data/redis/connection/jedis/StreamConvertersUnitTest.java

@@ -0,0 +1,30 @@
+package org.springframework.data.redis.connection.jedis;
+
+import static org.assertj.core.api.Assertions.*;
+
+import redis.clients.jedis.params.XPendingParams;
+
+import java.lang.reflect.Field;
+import java.time.Duration;
+import java.time.temporal.ChronoUnit;
+
+import org.junit.jupiter.api.Test;
+import org.springframework.data.redis.connection.RedisStreamCommands.XPendingOptions;
+
+/**
+ * @author Jeonggyu Choi
+ */
+class StreamConvertersUnitTest {
+
+	@Test // GH-2046
+	void shouldConvertIdle() throws NoSuchFieldException, IllegalAccessException {
+		XPendingOptions options = XPendingOptions.unbounded(5L).idle(Duration.of(1, ChronoUnit.HOURS));
+
+		XPendingParams xPendingParams = StreamConverters.toXPendingParams(options);
+
+		Field idle = XPendingParams.class.getDeclaredField("idle");
+		idle.setAccessible(true);
+		Long idleValue = (Long) idle.get(xPendingParams);
+		assertThat(idleValue).isEqualTo(Duration.of(1, ChronoUnit.HOURS).toMillis());
+	}
+}