Apply timing stats recording to remaining amqp processors.

r2/r2/lib/media.py

@@ -174,6 +174,7 @@ def force_thumbnail(link, image_data, never_expire=True, file_type=".jpg"):
     update_link(link, thumbnail=thumb_url, media_object=None, thumbnail_size=image.size)
 
 def run():
+    @g.stats.amqp_processor
     def process_link(msg):
         def _process_link(fname):
             link = Link._by_fullname(fname, data=True)

r2/r2/lib/solrsearch.py

@@ -687,5 +687,6 @@ def run_changed(drain=False):
                 for i in delete_things:
                     s.delete(id=i._fullname)
 
+    @g.stats.amqp_processor
     amqp.handle_items('solrsearch_changes', _run_changed, limit=1000,
                       drain=drain)