sylvain/agents_core
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

feat(mqtt): add unsubscribe() method to MQTTClient

Browse Source 
Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com>
This commit is contained in:
sylvain
2026-03-12 14:30:30 +00:00
parent 0dd871950f
commit f71cd0d48d
1 changed files with 7 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files
agents_core/mqtt_client.py
+7
View File
@@ -173,6 +173,13 @@ class MQTTClient:
self.client.subscribe(topic, qos=1) self.client.subscribe(topic, qos=1)
logger.debug(f"[{self.agent_id}] Abonné à {topic}") logger.debug(f"[{self.agent_id}] Abonné à {topic}")
def unsubscribe(self, topic: str):
"""Se désabonner d'un topic."""
with self._lock:
self._subscriptions.pop(topic, None)
self.client.unsubscribe(topic)
logger.debug(f"[{self.agent_id}] Désabonné de {topic}")
def subscribe_inbox(self, callback: Callable): def subscribe_inbox(self, callback: Callable):
"""S'abonner à sa propre inbox.""" """S'abonner à sa propre inbox."""
self.subscribe(self.topic_inbox(), callback) self.subscribe(self.topic_inbox(), callback)