gistfile1.rb

  def call(worker, msg, queue)
    begin
      if msg['retry_count'] && msg['retry_count'] >= @max_retries
         .....
         .....
      else
        yield
      end
    rescue => e
      raise
    end
  end