Method: Lolitra::RabbitmqBus#process_deadletters

Defined in:
lib/lolitra/rabbitmq_bus.rb

#process_deadletters(handler_class) ⇒ Object 



92
93
94
95
96
97
98
99
100
101
102
103
104
105
 
# File 'lib/lolitra/rabbitmq_bus.rb', line 92

def process_deadletters(handler_class)
  queue_name_dead = generate_queue_name_dead(handler_class)
  options = SUBSCRIBE_OPTIONS 
  create_channel(self.connection) do |channel|
    begin
      channel.queue(queue_name_dead, options.merge(@options[:queue_dead_params])) do |queue|
        recursive_pop(channel, queue, handler_class)
      end
    rescue => e
      Lolitra::log_exception(e)
    end
  end
  true
end