@@ -170,7 +170,7 @@ |
||
170 | 170 | * @param array $fieldGroupIdentifierList |
171 | 171 | * @param int $maxConcurrentJobsCount |
172 | 172 | * |
173 | - * @return bool |
|
173 | + * @return integer |
|
174 | 174 | */ |
175 | 175 | private function calculateAvailableSlotsCount($lockNames, $fieldGroupIdentifierList, $maxConcurrentJobsCount) |
176 | 176 | { |
@@ -3,7 +3,6 @@ |
||
3 | 3 | namespace Itkg\DelayEventBundle\Command; |
4 | 4 | |
5 | 5 | use Itkg\DelayEventBundle\Handler\LockHandlerInterface; |
6 | -use Itkg\DelayEventBundle\Model\Event; |
|
7 | 6 | use Itkg\DelayEventBundle\Model\Lock; |
8 | 7 | use Itkg\DelayEventBundle\Processor\EventProcessor; |
9 | 8 | use Itkg\DelayEventBundle\Repository\EventRepository; |
@@ -126,7 +126,7 @@ discard block |
||
126 | 126 | /** @var Lock $lock */ |
127 | 127 | foreach ($locks as $lock) { |
128 | 128 | if ($lock->isCommandLocked()) { |
129 | - $lockNames[] = str_replace(sprintf('%s_', $channel), '', $lock->getChannel()) ; |
|
129 | + $lockNames[] = str_replace(sprintf('%s_', $channel), '', $lock->getChannel()); |
|
130 | 130 | } |
131 | 131 | } |
132 | 132 | |
@@ -174,7 +174,7 @@ discard block |
||
174 | 174 | */ |
175 | 175 | private function calculateAvailableSlotsCount($lockNames, $fieldGroupIdentifierList, $maxConcurrentJobsCount) |
176 | 176 | { |
177 | - $concurrentJobsCount = count(array_intersect($fieldGroupIdentifierList , $lockNames)); |
|
177 | + $concurrentJobsCount = count(array_intersect($fieldGroupIdentifierList, $lockNames)); |
|
178 | 178 | |
179 | 179 | return $maxConcurrentJobsCount - $concurrentJobsCount; |
180 | 180 | } |