diff --git a/synapse/storage/receipts.py b/synapse/storage/receipts.py
index 9747a04a9a87323b05ad2bc1120b7c30b5118e82..f72d15f5ed33a0c85d9606f64c9acb94edfbe6d1 100644
--- a/synapse/storage/receipts.py
+++ b/synapse/storage/receipts.py
@@ -405,7 +405,7 @@ class ReceiptsStore(SQLBaseStore):
             room_id, receipt_type, user_id, event_ids, data
         )
 
-        max_persisted_id = self._stream_id_gen.get_current_token()
+        max_persisted_id = self._receipts_id_gen.get_current_token()
 
         defer.returnValue((stream_id, max_persisted_id))