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

[Question] Provide max_msgs through jetstream subscriber #247

Open
c0rv4x opened this issue Dec 24, 2021 · 0 comments
Open

[Question] Provide max_msgs through jetstream subscriber #247

c0rv4x opened this issue Dec 24, 2021 · 0 comments

Comments

@c0rv4x
Copy link

c0rv4x commented Dec 24, 2021

Classic subscriber has a way to define max_msgs variable, which is responsible for maximum messages a subscriber can process.

https://github.com/nats-io/nats.py/blob/main/nats/aio/client.py#L728

However JS has no way to supply that variable https://github.com/nats-io/nats.py/blob/main/nats/js/client.py#L288

Am I missing something? How can I create a Jetstream client which would be able to process only limited number of messages and then die?

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