Method: Lolitra::RabbitmqBus#purge_deadletters

Defined in:
lib/lolitra/rabbitmq_bus.rb

#purge_deadletters(handler_class) ⇒ Object 



107
108
109
110
111
112
113
114
115
116
117
118
119
120
 
# File 'lib/lolitra/rabbitmq_bus.rb', line 107

def purge_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|
        purge_queue(queue)
      end
    rescue => e
      Lolitra::log_exception(e)
    end
  end
  true
end