gistfile1.rb

begin
  users_queue.subscribe(:manual_ack => true, :block => true) do |delivery_info, properties, body|
    sf, wm, em = *JSON.parse(body)
    p [sf, wm , em]
    urls = get_urls(sf, wm, em)
    urls.each do |url|
      url_queue.publish(url.to_json)
    end
    puts " [x] Queued #{urls.size} urls for #{em}"
    users_channel.ack(delivery_info.delivery_tag)
    count += 1
    raise Interrupt, "Restart me" if count > 200
  end
rescue Interrupt => _
  conn.close
end