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