Merge pull request #135 from smartboxgroup/feature/delay-interceptor

jams246 · web-flow · commit 7aec71bdb5ab · 2022-06-10T14:21:03.000+01:00
bugfix/feature/delay-interceptor
diff --git a/Core/Processors/ControlFlow/DelayInterceptor.php b/Core/Processors/ControlFlow/DelayInterceptor.php
@@ -53,7 +53,7 @@ protected function doProcess(Exchange $exchange, SerializableArray $processingCo
     {
         $delayPeriodInSeconds = $exchange->getIn()->getHeader('delay') ?? null;
 
-        if (!is_null($delayPeriodInSeconds)) {
+        if (!is_null($delayPeriodInSeconds) && (int) $delayPeriodInSeconds > 0) {
             throw new DelayException();
         }
     }

Original file line number	Diff line number	Diff line change
`@@ -53,7 +53,7 @@ protected function doProcess(Exchange $exchange, SerializableArray $processingCo`
`53`	`53`	`{`
`54`	`54`	`$delayPeriodInSeconds = $exchange->getIn()->getHeader('delay') ?? null;`
`55`	`55`
`56`		`- if (!is_null($delayPeriodInSeconds)) {`
	`56`	`+ if (!is_null($delayPeriodInSeconds) && (int) $delayPeriodInSeconds > 0) {`
`57`	`57`	`throw new DelayException();`
`58`	`58`	`}`
`59`	`59`	`}`