search

copiousfreetime / qup

Qup is a generalized Ruby API for Message Queue and Publish/Subscribe messaging patterns.
ISC License
31 stars 4 forks source link

Non blocking consume #7

Closed rafer closed 12 years ago

rafer commented 12 years ago

Changed Kestrel and Redis adapters to do a non-blocking consume. Set kestrel timeout to 0 (prevents raising Qup::Adapter::Kestrel::Thrift::Kestrel::Client::TransportException).