Method: AMQ::Client::Async::Consumer#resubscribe

Defined in:
lib/amq/client/async/consumer.rb

#resubscribe(&block) ⇒ Object

Used by automatic recovery code.



74
75
76
77
78
79
 
# File 'lib/amq/client/async/consumer.rb', line 74

def resubscribe(&block)
  @connection.send_frame(Protocol::Basic::Consume.encode(@channel.id, @queue.name, @consumer_tag, @no_local, @no_ack, @exclusive, block.nil?, @arguments))
  self.redefine_callback(:consume, &block) if block

  self
end