修复并发工作回调返回值问题

imiphp · Jan 10, 2019 · b7a2f25 · b7a2f25
1 parent 2dcbc4c
commit b7a2f25
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/src/Aspect/WorkerLimitAspect.php b/src/Aspect/WorkerLimitAspect.php
@@ -37,13 +37,13 @@ public function parse(AroundJoinPoint $joinPoint)
         if(null === $blockingConsumer)
         {
             $result = WorkerLimiter::call(function() use($joinPoint){
-                $joinPoint->proceed();
+                return $joinPoint->proceed();
             }, $workerLimit->name, $workerLimit->max, $workerLimit->timeout, $workerLimit->callback, $workerLimit->poolName);
         }
         else
         {
             $result = WorkerLimiter::callBlock(function() use($joinPoint){
-                $joinPoint->proceed();
+                return $joinPoint->proceed();
             }, $workerLimit->name, $workerLimit->max, $workerLimit->timeout, $blockingConsumer->timeout, $workerLimit->callback, $workerLimit->poolName);
         }
         return $result;