Release v0.4.0
Added
- Subscriptions now raise slow consumer exceptions when hitting limits that can be customized via
:pending_msgs_limit
and:pending_bytes_limit
options that can be passed onsubscribe
.
nats.subscribe("hi", pending_msgs_limit: 100, pending_bytes_limit: 1024) do |payload|
# ...
end
Fixed
- Multiple async subscribers head of line blocking issue fixed (#27)
Changed
- Subscribers with callbacks now each have their own thread for dispatching messages following similar behavior as with the Go client (#27)
Removed
None
Deprecated
None