diff --git a/sat/memory/sqla.py b/sat/memory/sqla.py
index 5044aff6..263d3289 100644
--- a/sat/memory/sqla.py
+++ b/sat/memory/sqla.py
@@ -1224,6 +1224,7 @@ class Storage:
         self,
         node: PubsubNode,
         max_items: Optional[int] = None,
+        item_ids: Optional[list[str]] = None,
         before: Optional[str] = None,
         after: Optional[str] = None,
         from_index: Optional[int] = None,
@@ -1279,6 +1280,9 @@ class Storage:
             .limit(max_items)
         )
 
+        if item_ids is not None:
+            stmt = stmt.where(PubsubItem.name.in_(item_ids))
+
         if not order_by:
             order_by = [C.ORDER_BY_MODIFICATION]