增加扩展阻止下级消息传播

TobyQu · Jul 7, 2017 · b882191 · b882191
1 parent 57af778
commit b882191
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/src/Extension/MessageExtension.php b/src/Extension/MessageExtension.php
@@ -94,7 +94,9 @@ private function initBaseExtensions()
     public function exec($collection)
     {
         foreach ($this->serviceExtensions as $extension) {
-            $extension->messageHandler($collection);
+            if ($extension->messageHandler($collection)) {
+                return;
+            }
         }
     }