-
Notifications
You must be signed in to change notification settings - Fork 1.2k
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Add idle
attribute for xpending
command
#2101
Conversation
- added the support for idle attribute support for xpending commands in reactive stream commands and redis stream commands
@SivaTharun Please sign the Contributor License Agreement! Click here to manually synchronize the status of this Pull Request. See the FAQ for frequently asked questions. |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Thanks a lot. I had a look and the code looks pretty decent. It would make sense to add integration tests (see AbstractConnectionIntegrationTests
and LettuceReactiveStreamCommandsIntegrationTests
).
* @see <a href="https://redis.io/commands/xpending">Redis Documentation: xpending</a> | ||
* @since 2.3 | ||
*/ | ||
PendingMessages pending(K key, String group, Range<?> range, long count, long idleMilliSeconds); |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
For both added methods (pending
), it would make sense to accept idleTime
as long
and have a TimeUnit
to avoid potential conversion bugs in calling code.
* @return pending messages for the given {@literal consumer group} or {@literal null} when used in pipeline / | ||
* transaction. | ||
* @see <a href="https://redis.io/commands/xpending">Redis Documentation: xpending</a> | ||
* @since 2.3 |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
@since
should point to version 2.6
in all newly introduced methods.
idle
attribute for xpending
command
@SivaTharun any update on the comments @mp911de had? |
@christophstrobl i am currently addressing the comments, and will be ready in a couple of days. sure i will sign in the CLA |
…nto issue/2046 # Conflicts: # src/main/java/org/springframework/data/redis/connection/DefaultStringRedisConnection.java
Closing due to lack of requested feedback. If you would like us to look at this issue, please provide the requested information and we will re-open the issue. |
Overview
idle attribute support for redis xpending stream commands
Connects #2046