-
Notifications
You must be signed in to change notification settings - Fork 37
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
Cannot reproduce interest-based Streams example with Java SDK #203
Comments
@thomasdarimont As far as double ack, do you mean acking and waiting for the server to respond to ensure the ack was received? If that is the case you are looking for
|
@thomasdarimont What do you expect the behavior of double ack to be? ackSync behavior waits for the server to respond for the length of the timeout. ackSync blocks until it gets a response or it times out. A response from the server indicates it has processed the ack.
|
@thomasdarimont I'm planning on closing this issue unless I hear back from you. |
Hello @scottf sorry for the late response. I'm trying to replicate the go/rust examples as close as possible for a talk at our local Java User Group. Since not all NATs use-cases have Java examples, I tried to add a Java example for every NATs use-case. I expected that there is an explicit equivalent for Message#DoubleAck as used here: Even with If |
Observed behavior
The Java SDK currently lacks some functionality like "double ack" to reproduce the example.
Expected behavior
The Java SDK should offer the same functionality as the other language integrations.
Server and client version
Nats Server Version: 2.10.14
Java SDK:
Host environment
No response
Steps to reproduce
Inspect and compare the following program with https://natsbyexample.com/examples/jetstream/interest-stream/rust
Maven POM excerpt:
Serde helper class:
The text was updated successfully, but these errors were encountered: