diff --git a/sat/plugins/plugin_pubsub_cache.py b/sat/plugins/plugin_pubsub_cache.py
index b3497db1..31aac1fb 100644
--- a/sat/plugins/plugin_pubsub_cache.py
+++ b/sat/plugins/plugin_pubsub_cache.py
@@ -389,7 +389,6 @@ class PubsubCache:
                 analyse["conf"] = conf
 
         for analyser in self.analysers.values():
-            match_cb = analyser.get("match_cb")
             try:
                 an_node = analyser["node"]
             except KeyError:
@@ -429,7 +428,7 @@ class PubsubCache:
             except KeyError:
                 pass
             else:
-                await match_cb(client, analyse)
+                await utils.asDeferred(match_cb, client, analyse)
         return analyse
 
     def _getItemsFromCache(