nats-io/nats.py v2.1.5

Release v2.1.5

on GitHub

Added

• Added pending_msgs_limit and pending_bytes_limit can now be set for push and pull consumers from JetStream. To disable limits -1 can be used instead:

# Push Subscriber
await js.subscribe("push-example", pending_bytes_limit=-1, pending_msgs_limit=-1)

# Pull Subscriber
await js.pull_subscribe("pull-example", "durable", pending_msgs_limit=-1, pending_bytes_limit=-1)

• Added sub.pending_bytes and sub.pending_msgs methods to confirm buffered bytes and messages from a Subscription

Fixed

• Fixed accounting bug when using sub.next_msg which would have caused SlowConsumer errors and dropping messages when reaching default limit

• Fixed empty message being returned sometimes when calling sub.next_msg after future was cancelled