diff --git a/ltk/pubsub.py b/ltk/pubsub.py
index 5ccbba6..85a4f6b 100644
--- a/ltk/pubsub.py
+++ b/ltk/pubsub.py
@@ -101,6 +101,7 @@ def publish(self, sender, receiver, topic, data):
         if show_publish:
             _logger.info(f"[Pubsub] {json.dumps(['publish', sender, receiver, topic, str(data)[:32]])}")
         self.process_queue()
+        schedule(self.process_queue, 100)
 
     def subscribe(self, name, topic, handler):
         self.subscribers.append([name, topic, handler])