lib/bunny/concurrent/continuation_queue.rb in bunny-1.0.0.pre4 vs lib/bunny/concurrent/continuation_queue.rb in bunny-1.0.0.pre5
- old
+ new
@@ -19,10 +19,10 @@
@q.pop
end
def poll(timeout_in_ms = nil)
if timeout_in_ms
- Bunny::Timer.timeout(timeout_in_ms / 1000, Timeout::Error) do
+ Bunny::Timeout.timeout(timeout_in_ms / 1000, Timeout::Error) do
@q.pop
end
else
@q.pop
end