diff --git a/trustgraph-flow/trustgraph/librarian/service.py b/trustgraph-flow/trustgraph/librarian/service.py
index 55f7ec27..48bb0190 100755
--- a/trustgraph-flow/trustgraph/librarian/service.py
+++ b/trustgraph-flow/trustgraph/librarian/service.py
@@ -306,7 +306,7 @@ class Processor(AsyncProcessor):
         logger.debug(f"Submitting to queue {q}...")
 
         pub = Publisher(
-            self.pulsar_client, q, schema=schema
+            self.pubsub, q, schema=schema
         )
 
         await pub.start()