Method: AMQP::Channel#recover

Defined in:
lib/amqp/channel.rb

#recover(requeue = true, &block) ⇒ Channel

Note:

RabbitMQ as of 2.3.1 does not support basic.recover with requeue = false.

Notifies AMQ broker that consumer has recovered and unacknowledged messages need to be redelivered.

Returns:

See Also:



1052
1053
1054
1055
1056
1057
 
# File 'lib/amqp/channel.rb', line 1052

def recover(requeue = true, &block)
  @connection.send_frame(AMQ::Protocol::Basic::Recover.encode(@id, requeue))

  self.redefine_callback :recover, &block
  self
end