lib/bunny/channel.rb in bunny-1.0.7 vs lib/bunny/channel.rb in bunny-1.1.0.pre1
- old
+ new
@@ -1679,11 +1679,11 @@
@basic_get_continuations.poll(@connection.continuation_timeout)
ensure
@threads_waiting_on_basic_get_continuations.delete(t)
end
else
- connection.reader_loop.run_once until @basic_get_continuations.length > 0
+ connection.event_loop.run_once until @basic_get_continuations.length > 0
@basic_get_continuations.pop
end
end
@@ -1697,10 +1697,10 @@
@confirms_continuations.poll(@connection.continuation_timeout)
ensure
@threads_waiting_on_confirms_continuations.delete(t)
end
else
- connection.reader_loop.run_once until @confirms_continuations.length > 0
+ connection.event_loop.run_once until @confirms_continuations.length > 0
@confirms_continuations.pop
end
end