diff --git a/libs/service/hive/service/service.py b/libs/service/hive/service/service.py
index e8bc386..76efd2f 100644
--- a/libs/service/hive/service/service.py
+++ b/libs/service/hive/service/service.py
@@ -66,5 +66,5 @@ def publisher_connection(self, **kwargs) -> Connection:
         return self._connect(publisher_connection, kwargs)
 
     def _connect(self, connect, kwargs) -> Connection:
-        on_channel_open = kwargs.get("on_channel_open", self.on_channel_open)
+        on_channel_open = kwargs.pop("on_channel_open", self.on_channel_open)
         return connect(on_channel_open=on_channel_open, **kwargs)