# File lib/amqp/channel.rb, line 981 def prefetch(count, global = false, &block) self.once_open do # RabbitMQ as of 2.3.1 does not support prefetch_size. self.qos(0, count, global, &block) end self end