Skip to content
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

Java: Add XACK stream command #380

Merged
merged 8 commits into from
Jun 20, 2024

Conversation

acarbonetto
Copy link

Dependent on XREADGROUP PR: valkey-io#1613

Adds the XACK command.

acarbonetto and others added 5 commits June 19, 2024 20:34
* Add XGROUP CreateConsumer, DelConsumer

Signed-off-by: Andrew Carbonetto <[email protected]>

* Add XREADGROUP command

Signed-off-by: Andrew Carbonetto <[email protected]>

* Udpate IT tests

Signed-off-by: Andrew Carbonetto <[email protected]>

* Fix IT tests

Signed-off-by: Andrew Carbonetto <[email protected]>

* SPOTLESS & merge conflict fix

Signed-off-by: Andrew Carbonetto <[email protected]>

* Update for review comments

Signed-off-by: Andrew Carbonetto <[email protected]>

---------

Signed-off-by: Andrew Carbonetto <[email protected]>
Signed-off-by: Andrew Carbonetto <[email protected]>
Signed-off-by: Andrew Carbonetto <[email protected]>
Signed-off-by: Andrew Carbonetto <[email protected]>
@acarbonetto acarbonetto force-pushed the java/dev_acarbo_xack branch from 326f06b to acdccf2 Compare June 20, 2024 03:42
Signed-off-by: Andrew Carbonetto <[email protected]>
Signed-off-by: Andrew Carbonetto <[email protected]>
Signed-off-by: Andrew Carbonetto <[email protected]>
@SneakyThrows
@ParameterizedTest(autoCloseArguments = false)
@MethodSource("getClients")
public void xack_return_failures(BaseClient client) {
Copy link

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Should rename since it doesn't return all failures

Copy link
Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

all the xack calls return failures?

@acarbonetto acarbonetto merged commit 4412d19 into java/integ_acarbo_xack Jun 20, 2024
11 checks passed
@acarbonetto acarbonetto deleted the java/dev_acarbo_xack branch June 20, 2024 19:37
aaron-congo pushed a commit that referenced this pull request Jun 21, 2024
* Java: Add XACK stream command (#380)

Signed-off-by: Andrew Carbonetto <[email protected]>
Co-authored-by: Guian Gumpac <[email protected]>
Co-authored-by: Yi-Pin Chen <[email protected]>
cyip10 pushed a commit that referenced this pull request Jun 24, 2024
* Java: Add XACK stream command (#380)

Signed-off-by: Andrew Carbonetto <[email protected]>
Co-authored-by: Guian Gumpac <[email protected]>
Co-authored-by: Yi-Pin Chen <[email protected]>
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

Successfully merging this pull request may close these issues.

3 participants