You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
{{ message }}
This repository has been archived by the owner on Mar 29, 2022. It is now read-only.
The Pwwka::Receiver.subscribe class method creates a new Pwwka::Receiver which executed the provided handler once per message delivered to a queue (which it creates) bound to each routing key in the routing_key argument. If the block: false argument is provided, the Bunny subscription should be created in a non-blocking fashion, i.e. the call to Bunny::Queue#subscribe should return immediately, and the Pwwka::Receiver should be returned.
Problem
The
Pwwka::Receiver.subscribe
class method creates a newPwwka::Receiver
which executed the provided handler once per message delivered to a queue (which it creates) bound to each routing key in therouting_key
argument. If theblock: false
argument is provided, the Bunny subscription should be created in a non-blocking fashion, i.e. the call toBunny::Queue#subscribe
should return immediately, and thePwwka::Receiver
should be returned.Unfortunately, the
Pwwka::Receiver.subscribe
'sensure
block closes the underlying connection before the receiver is returned, rendering the receiver unusable.The text was updated successfully, but these errors were encountered: