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

Implement the same event processing mechanism as in Java lower-level API #17

Open
dartvandru opened this issue Sep 20, 2016 · 0 comments
Assignees

Comments

@dartvandru
Copy link
Collaborator

The lower-level API replaced acknowledgeable stream mechanism with a simple callback based API.

The dispatcherCallback returns a CompletableFuture (ie. Promise).
When it completes the implementation considers that message processed.
The order of messages to ACK must be preserved.I.e. the MESSAGE frames must be ACK’d in the order they are received.
For example, If there are messages A, B, and C then if the handler completes in this order C, B, A then the ACKs for B and C are not sent until A completes.

A MESSAGE frame’s ack header is an opaque token that should never be decoded - simply passed to the ACK frame.

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

No branches or pull requests

1 participant