diff --git a/r2/r2/lib/media.py b/r2/r2/lib/media.py
index bcbd3d6f7..63dc5529d 100644
--- a/r2/r2/lib/media.py
+++ b/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)
diff --git a/r2/r2/lib/solrsearch.py b/r2/r2/lib/solrsearch.py
index d51b04383..5e4dc0687 100644
--- a/r2/r2/lib/solrsearch.py
+++ b/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)