Skip to content

Commit c6efb27

Browse files
Merge pull request #42 from simstern/bugfix/maximumNumberOfReleases-default
BUGFIX: maximumNumberOfReleases default value
2 parents 84094bc + 9a16216 commit c6efb27

1 file changed

Lines changed: 8 additions & 1 deletion

File tree

Classes/Job/JobManager.php

Lines changed: 8 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -27,6 +27,11 @@
2727
*/
2828
class JobManager
2929
{
30+
/**
31+
* @var int
32+
*/
33+
const DEFAULT_MAXIMUM_NUMBER_RELEASES = 3;
34+
3035
/**
3136
* @Flow\Inject
3237
* @var QueueManager
@@ -108,7 +113,9 @@ public function waitAndExecute(string $queueName, $timeout = null): ?Message
108113
$this->executeJobForMessage($queue, $message);
109114
}
110115
} catch (\Exception $exception) {
111-
$maximumNumberOfReleases = isset($queueSettings['maximumNumberOfReleases']) ? (integer)$queueSettings['maximumNumberOfReleases'] : 0;
116+
$maximumNumberOfReleases = isset($queueSettings['maximumNumberOfReleases']) ?
117+
(int)$queueSettings['maximumNumberOfReleases'] :
118+
self::DEFAULT_MAXIMUM_NUMBER_RELEASES;
112119
if ($message->getNumberOfReleases() < $maximumNumberOfReleases) {
113120
$releaseOptions = isset($queueSettings['releaseOptions']) ? $queueSettings['releaseOptions'] : [];
114121
$queue->release($message->getIdentifier(), $releaseOptions);

0 commit comments

Comments
 (0)