Method: AMQP::Channel#prefetch

Defined in:
lib/amqp/channel.rb

#prefetch(count, global = false, &block) ⇒ Channel

Returns self.

Parameters:

  • Message (Fixnum) —

    count

  • global (Boolean) (defaults to: false) —

    (false)

Returns:



998
999
1000
1001
1002
1003
1004
1005
1006
1007
 
# File 'lib/amqp/channel.rb', line 998

def prefetch(count, global = false, &block)
  self.once_open do
    # RabbitMQ does not support prefetch_size.
    self.qos(0, count, global, &block)

    @options[:prefetch] = count
  end

  self
end