| @@ -69,7 +69,7 @@ discard block | ||
| 69 | 69 | $this->expressionLanguage, | 
| 70 | 70 | new ExpressionEncoderRegistry([]) | 
| 71 | 71 | ); | 
| 72 | - $this->blockFactory = new BlockFactory( | |
| 72 | + $this->blockFactory = new BlockFactory( | |
| 73 | 73 | $this->registry, | 
| 74 | 74 | $this->layoutManipulator, | 
| 75 | 75 | $expressionProcessor | 
| @@ -99,13 +99,13 @@ discard block | ||
| 99 | 99 | $view = $this->getLayoutView(); | 
| 100 | 100 | |
| 101 | 101 | $this->assertBlockView( | 
| 102 | - [ // root | |
| 102 | + [// root | |
| 103 | 103 | 'vars' => ['id' => 'root'], | 
| 104 | 104 | 'children' => [ | 
| 105 | - [ // header | |
| 105 | + [// header | |
| 106 | 106 | 'vars' => ['id' => 'header'], | 
| 107 | 107 | 'children' => [ | 
| 108 | - [ // logo | |
| 108 | + [// logo | |
| 109 | 109 | 'vars' => ['id' => 'logo', 'title' => 'test'] | 
| 110 | 110 | ] | 
| 111 | 111 | ] | 
| @@ -124,7 +124,7 @@ discard block | ||
| 124 | 124 | $view = $this->getLayoutView(); | 
| 125 | 125 | |
| 126 | 126 | $this->assertBlockView( | 
| 127 | - [ // root | |
| 127 | + [// root | |
| 128 | 128 | 'vars' => [ | 
| 129 | 129 | 'id' => 'rootId', | 
| 130 | 130 | 'block_type' => 'root', | 
| @@ -156,7 +156,7 @@ discard block | ||
| 156 | 156 | $view = $this->getLayoutView(); | 
| 157 | 157 | |
| 158 | 158 | $this->assertBlockView( | 
| 159 | - [ // root | |
| 159 | + [// root | |
| 160 | 160 | 'vars' => [ | 
| 161 | 161 | 'id' => 'rootId', | 
| 162 | 162 | 'block_type' => 'root', | 
| @@ -172,7 +172,7 @@ discard block | ||
| 172 | 172 | 'cache_key' => '_rootId_root' | 
| 173 | 173 | ], | 
| 174 | 174 | 'children' => [ | 
| 175 | - [ // header | |
| 175 | + [// header | |
| 176 | 176 | 'vars' => [ | 
| 177 | 177 | 'id' => 'headerId', | 
| 178 | 178 | 'block_type' => 'header', | 
| @@ -188,7 +188,7 @@ discard block | ||
| 188 | 188 | 'cache_key' => '_headerId_header' | 
| 189 | 189 | ], | 
| 190 | 190 | 'children' => [ | 
| 191 | - [ // logo | |
| 191 | + [// logo | |
| 192 | 192 | 'vars' => [ | 
| 193 | 193 | 'id' => 'logoId', | 
| 194 | 194 | 'block_type' => 'logo', | 
| @@ -247,7 +247,7 @@ discard block | ||
| 247 | 247 |              ->method('updateLayout') | 
| 248 | 248 | ->will( | 
| 249 | 249 | $this->returnCallback( | 
| 250 | -                    function (LayoutManipulatorInterface $layoutManipulator, LayoutItemInterface $item) { | |
| 250 | +                    function(LayoutManipulatorInterface $layoutManipulator, LayoutItemInterface $item) { | |
| 251 | 251 |                          $layoutManipulator->add('test', 'header', 'test'); | 
| 252 | 252 | } | 
| 253 | 253 | ) | 
| @@ -261,7 +261,7 @@ discard block | ||
| 261 | 261 |              ->method('configureOptions') | 
| 262 | 262 | ->will( | 
| 263 | 263 | $this->returnCallback( | 
| 264 | -                    function (OptionsResolver $resolver) { | |
| 264 | +                    function(OptionsResolver $resolver) { | |
| 265 | 265 | $resolver->setDefaults( | 
| 266 | 266 | [ | 
| 267 | 267 | 'test_option_1' => '', | 
| @@ -275,7 +275,7 @@ discard block | ||
| 275 | 275 |              ->method('buildBlock') | 
| 276 | 276 | ->will( | 
| 277 | 277 | $this->returnCallback( | 
| 278 | -                    function (BlockBuilderInterface $builder, Options $options) { | |
| 278 | +                    function(BlockBuilderInterface $builder, Options $options) { | |
| 279 | 279 |                          if ($options['test_option_1'] === 'move_logo_to_root') { | 
| 280 | 280 |                              $builder->getLayoutManipulator()->move('logo', 'root'); | 
| 281 | 281 | } | 
| @@ -286,7 +286,7 @@ discard block | ||
| 286 | 286 |              ->method('buildView') | 
| 287 | 287 | ->will( | 
| 288 | 288 | $this->returnCallback( | 
| 289 | -                    function (BlockView $view, BlockInterface $block, Options $options) { | |
| 289 | +                    function(BlockView $view, BlockInterface $block, Options $options) { | |
| 290 | 290 | $view->vars['attr']['block_id'] = $block->getId(); | 
| 291 | 291 |                          if ($options['test_option_1'] === 'move_logo_to_root') { | 
| 292 | 292 | $view->vars['attr']['logo_moved'] = true; | 
| @@ -299,7 +299,7 @@ discard block | ||
| 299 | 299 |              ->method('finishView') | 
| 300 | 300 | ->will( | 
| 301 | 301 | $this->returnCallback( | 
| 302 | -                    function (BlockView $view, BlockInterface $block) { | |
| 302 | +                    function(BlockView $view, BlockInterface $block) { | |
| 303 | 303 |                          if (isset($view['test'])) { | 
| 304 | 304 | $view['test']->vars['processed_by_header_extension'] = true; | 
| 305 | 305 | } | 
| @@ -327,10 +327,10 @@ discard block | ||
| 327 | 327 | $view = $this->getLayoutView(); | 
| 328 | 328 | |
| 329 | 329 | $this->assertBlockView( | 
| 330 | - [ // root | |
| 330 | + [// root | |
| 331 | 331 | 'vars' => ['id' => 'root'], | 
| 332 | 332 | 'children' => [ | 
| 333 | - [ // header | |
| 333 | + [// header | |
| 334 | 334 | 'vars' => [ | 
| 335 | 335 | 'id' => 'header', | 
| 336 | 336 | 'attr' => [ | 
| @@ -340,7 +340,7 @@ discard block | ||
| 340 | 340 | ] | 
| 341 | 341 | ], | 
| 342 | 342 | 'children' => [ | 
| 343 | - [ // test | |
| 343 | + [// test | |
| 344 | 344 | 'vars' => [ | 
| 345 | 345 | 'id' => 'test', | 
| 346 | 346 | 'processed_by_header_extension' => true | 
| @@ -348,7 +348,7 @@ discard block | ||
| 348 | 348 | ] | 
| 349 | 349 | ] | 
| 350 | 350 | ], | 
| 351 | - [ // logo | |
| 351 | + [// logo | |
| 352 | 352 | 'vars' => ['id' => 'logo', 'title' => 'test'] | 
| 353 | 353 | ] | 
| 354 | 354 | ] | 
| @@ -378,13 +378,13 @@ discard block | ||
| 378 | 378 | $view = $this->getLayoutView(); | 
| 379 | 379 | |
| 380 | 380 | $this->assertBlockView( | 
| 381 | - [ // root | |
| 381 | + [// root | |
| 382 | 382 | 'vars' => ['id' => 'root'], | 
| 383 | 383 | 'children' => [ | 
| 384 | - [ // header | |
| 384 | + [// header | |
| 385 | 385 | 'vars' => ['id' => 'header'], | 
| 386 | 386 | 'children' => [ | 
| 387 | - [ // logo | |
| 387 | + [// logo | |
| 388 | 388 | 'vars' => ['id' => 'logo', 'title' => 'test title'] | 
| 389 | 389 | ] | 
| 390 | 390 | ] | 
| @@ -459,13 +459,13 @@ discard block | ||
| 459 | 459 | $view = $this->getLayoutView(); | 
| 460 | 460 | |
| 461 | 461 | $this->assertBlockView( | 
| 462 | - [ // root | |
| 462 | + [// root | |
| 463 | 463 | 'vars' => ['id' => 'root'], | 
| 464 | 464 | 'children' => [ | 
| 465 | - [ // header | |
| 465 | + [// header | |
| 466 | 466 | 'vars' => ['id' => 'header'], | 
| 467 | 467 | 'children' => [ | 
| 468 | - [ // logo | |
| 468 | + [// logo | |
| 469 | 469 | 'vars' => ['id' => 'logo', 'title' => 'one two'] | 
| 470 | 470 | ] | 
| 471 | 471 | ] | 
| @@ -40,6 +40,6 @@ | ||
| 40 | 40 | */ | 
| 41 | 41 | public function isVisible() | 
| 42 | 42 |      { | 
| 43 | -        return array_key_exists('visible', $this->vars) ? (bool) $this->vars['visible'] : true; | |
| 43 | +        return array_key_exists('visible', $this->vars) ? (bool)$this->vars['visible'] : true; | |
| 44 | 44 | } | 
| 45 | 45 | } | 
| @@ -97,7 +97,7 @@ discard block | ||
| 97 | 97 | $this->typeHelper, | 
| 98 | 98 | $this->context | 
| 99 | 99 | ); | 
| 100 | - $this->block = new Block( | |
| 100 | + $this->block = new Block( | |
| 101 | 101 | $this->rawLayout, | 
| 102 | 102 | $this->typeHelper, | 
| 103 | 103 | $this->context, | 
| @@ -234,7 +234,7 @@ discard block | ||
| 234 | 234 | $view = new BlockView($parentView); | 
| 235 | 235 | |
| 236 | 236 |          if (is_null($resolvedOptions)) { // Try to resolve options again to render block | 
| 237 | - $options = $this->rawLayout->getProperty($id, RawLayout::OPTIONS, true); | |
| 237 | + $options = $this->rawLayout->getProperty($id, RawLayout::OPTIONS, true); | |
| 238 | 238 | $resolvedOptions = $this->setBlockResolvedOptions($id, $blockType, $options, $types); | 
| 239 | 239 | } | 
| 240 | 240 | |
| @@ -248,7 +248,7 @@ discard block | ||
| 248 | 248 | |
| 249 | 249 | array_walk_recursive( | 
| 250 | 250 | $view->vars, | 
| 251 | -            function (&$var) { | |
| 251 | +            function(&$var) { | |
| 252 | 252 |                  if ($var instanceof Options) { | 
| 253 | 253 | $var = $var->toArray(); | 
| 254 | 254 | } | 
| @@ -60,7 +60,7 @@ discard block | ||
| 60 | 60 | $loader | 
| 61 | 61 | ->expects($this->any()) | 
| 62 | 62 |              ->method('loadClassMetadata') | 
| 63 | -            ->will($this->returnCallback(function (ClassMetadata $meta) { | |
| 63 | +            ->will($this->returnCallback(function(ClassMetadata $meta) { | |
| 64 | 64 | $this->loadMetadata($meta); | 
| 65 | 65 | })); | 
| 66 | 66 | |
| @@ -155,7 +155,7 @@ discard block | ||
| 155 | 155 | |
| 156 | 156 | $factory->expects($this->any()) | 
| 157 | 157 |              ->method('getInstance') | 
| 158 | -            ->will($this->returnCallback(function (Constraint $constraint) { | |
| 158 | +            ->will($this->returnCallback(function(Constraint $constraint) { | |
| 159 | 159 | $className = $constraint->validatedBy(); | 
| 160 | 160 | |
| 161 | 161 | if (!isset($this->validators[$className]) | 
| @@ -181,13 +181,13 @@ discard block | ||
| 181 | 181 | |
| 182 | 182 | $translator->expects($this->any()) | 
| 183 | 183 |              ->method('trans') | 
| 184 | -            ->will($this->returnCallback(function ($id) { | |
| 184 | +            ->will($this->returnCallback(function($id) { | |
| 185 | 185 | return $id; | 
| 186 | 186 | })) | 
| 187 | 187 | ; | 
| 188 | 188 | $translator->expects($this->any()) | 
| 189 | 189 |              ->method('transChoice') | 
| 190 | -            ->will($this->returnCallback(function ($id) { | |
| 190 | +            ->will($this->returnCallback(function($id) { | |
| 191 | 191 | return $id; | 
| 192 | 192 | })) | 
| 193 | 193 | ; | 
| @@ -147,7 +147,7 @@ discard block | ||
| 147 | 147 | } | 
| 148 | 148 | |
| 149 | 149 | $em = $this->getEntityManager(true); | 
| 150 | -            $em->getConnection()->transactional(function (Connection $connection) use ($em, $job, $lockCallback) { | |
| 150 | +            $em->getConnection()->transactional(function(Connection $connection) use ($em, $job, $lockCallback) { | |
| 151 | 151 | /** @var Job $job */ | 
| 152 | 152 | $job = $em->find($this->entityClass, $job->getId(), LockMode::PESSIMISTIC_WRITE); | 
| 153 | 153 | |
| @@ -167,7 +167,7 @@ discard block | ||
| 167 | 167 | // exception occurs but UniqueConstraintViolationException is expected here | 
| 168 | 168 | // and we should keep EntityManager in open state. | 
| 169 | 169 | $em = $this->getEntityManager(true); | 
| 170 | -                $em->getConnection()->transactional(function (Connection $connection) use ($job, $em) { | |
| 170 | +                $em->getConnection()->transactional(function(Connection $connection) use ($job, $em) { | |
| 171 | 171 |                      try { | 
| 172 | 172 | $connection->insert($this->uniqueTableName, ['name' => $job->getOwnerId()]); | 
| 173 | 173 |                          if ($job->isUnique()) { | 
| @@ -50,14 +50,14 @@ discard block | ||
| 50 | 50 |      { | 
| 51 | 51 | $data = JSON::decode($message->getBody()); | 
| 52 | 52 | |
| 53 | -        if (! isset($data['jobId'])) { | |
| 53 | +        if (!isset($data['jobId'])) { | |
| 54 | 54 |              $this->logger->critical('Got invalid message'); | 
| 55 | 55 | |
| 56 | 56 | return self::REJECT; | 
| 57 | 57 | } | 
| 58 | 58 | |
| 59 | 59 | $job = $this->jobStorage->findJobById($data['jobId']); | 
| 60 | -        if (! $job) { | |
| 60 | +        if (!$job) { | |
| 61 | 61 | $this->logger->critical( | 
| 62 | 62 |                  sprintf('Job was not found. id: "%s"', $data['jobId']) | 
| 63 | 63 | ); | 
| @@ -91,7 +91,7 @@ discard block | ||
| 91 | 91 | } | 
| 92 | 92 | |
| 93 | 93 | $progress = round($processed / $numberOfChildren, 4); | 
| 94 | -        $this->jobStorage->saveJob($rootJob, function (Job $rootJob) use ($progress) { | |
| 94 | +        $this->jobStorage->saveJob($rootJob, function(Job $rootJob) use ($progress) { | |
| 95 | 95 |              if ($progress !== $rootJob->getJobProgress()) { | 
| 96 | 96 | $rootJob->setJobProgress($progress); | 
| 97 | 97 | } | 
| @@ -90,11 +90,11 @@ discard block | ||
| 90 | 90 | */ | 
| 91 | 91 | public function findOrCreateRootJob($ownerId, $jobName, $unique = false) | 
| 92 | 92 |      { | 
| 93 | -        if (! $ownerId) { | |
| 93 | +        if (!$ownerId) { | |
| 94 | 94 |              throw new \LogicException('OwnerId must not be empty'); | 
| 95 | 95 | } | 
| 96 | 96 | |
| 97 | -        if (! $jobName) { | |
| 97 | +        if (!$jobName) { | |
| 98 | 98 |              throw new \LogicException('Job name must not be empty'); | 
| 99 | 99 | } | 
| 100 | 100 | |
| @@ -111,7 +111,7 @@ discard block | ||
| 111 | 111 | $job->setLastActiveAt(new \DateTime()); | 
| 112 | 112 | $job->setStartedAt(new \DateTime()); | 
| 113 | 113 | $job->setJobProgress(0); | 
| 114 | - $job->setUnique((bool) $unique); | |
| 114 | + $job->setUnique((bool)$unique); | |
| 115 | 115 | |
| 116 | 116 | return $this->saveJobAndStaleDuplicateIfQualifies($job); | 
| 117 | 117 | } | 
| @@ -151,7 +151,7 @@ discard block | ||
| 151 | 151 | |
| 152 | 152 | $timeBeforeStale = $this->getJobConfigurationProvider()->getTimeBeforeStaleForJobName($job->getName()); | 
| 153 | 153 |          if ($timeBeforeStale !== null && $timeBeforeStale != -1) { | 
| 154 | -            return $job->getLastActiveAt() <= new \DateTime('- ' . $timeBeforeStale. ' seconds'); | |
| 154 | +            return $job->getLastActiveAt() <= new \DateTime('- ' . $timeBeforeStale . ' seconds'); | |
| 155 | 155 | } | 
| 156 | 156 | |
| 157 | 157 | return false; | 
| @@ -181,7 +181,7 @@ discard block | ||
| 181 | 181 | */ | 
| 182 | 182 | public function findOrCreateChildJob($jobName, Job $rootJob) | 
| 183 | 183 |      { | 
| 184 | -        if (! $jobName) { | |
| 184 | +        if (!$jobName) { | |
| 185 | 185 |              throw new \LogicException('Job name must not be empty'); | 
| 186 | 186 | } | 
| 187 | 187 | |
| @@ -217,7 +217,7 @@ discard block | ||
| 217 | 217 | |
| 218 | 218 | $job = $this->jobStorage->findJobById($job->getId()); | 
| 219 | 219 | |
| 220 | -        if (! in_array($job->getStatus(), $this->getNotStartedJobStatuses(), true)) { | |
| 220 | +        if (!in_array($job->getStatus(), $this->getNotStartedJobStatuses(), true)) { | |
| 221 | 221 | throw new \LogicException(sprintf( | 
| 222 | 222 | 'Can start only new jobs: id: "%s", status: "%s"', | 
| 223 | 223 | $job->getId(), | 
| @@ -280,7 +280,7 @@ discard block | ||
| 280 | 280 |              throw new \LogicException(sprintf('Can\'t stale child jobs. id: "%s"', $rootJob->getId())); | 
| 281 | 281 | } | 
| 282 | 282 | |
| 283 | -        $this->jobStorage->saveJob($rootJob, function (Job $rootJob) { | |
| 283 | +        $this->jobStorage->saveJob($rootJob, function(Job $rootJob) { | |
| 284 | 284 | $rootJob->setStatus(Job::STATUS_STALE); | 
| 285 | 285 | $rootJob->setStoppedAt(new \DateTime()); | 
| 286 | 286 | |
| @@ -359,7 +359,7 @@ discard block | ||
| 359 | 359 | |
| 360 | 360 | $job = $this->jobStorage->findJobById($job->getId()); | 
| 361 | 361 | |
| 362 | -        if (! in_array($job->getStatus(), $this->getActiveJobStatuses(), true)) { | |
| 362 | +        if (!in_array($job->getStatus(), $this->getActiveJobStatuses(), true)) { | |
| 363 | 363 | throw new \LogicException(sprintf( | 
| 364 | 364 | 'Can cancel only new or running jobs. id: "%s", status: "%s"', | 
| 365 | 365 | $job->getId(), | 
| @@ -370,7 +370,7 @@ discard block | ||
| 370 | 370 | $job->setStatus(Job::STATUS_CANCELLED); | 
| 371 | 371 | $job->setStoppedAt($stoppedAt = new \DateTime()); | 
| 372 | 372 | |
| 373 | -        if (! $job->getStartedAt()) { | |
| 373 | +        if (!$job->getStartedAt()) { | |
| 374 | 374 | $job->setStartedAt($stoppedAt); | 
| 375 | 375 | } | 
| 376 | 376 | |
| @@ -428,7 +428,7 @@ discard block | ||
| 428 | 428 | return; | 
| 429 | 429 | } | 
| 430 | 430 | |
| 431 | -        $this->jobStorage->saveJob($job, function (Job $job) use ($force) { | |
| 431 | +        $this->jobStorage->saveJob($job, function(Job $job) use ($force) { | |
| 432 | 432 |              if ($job->isInterrupted()) { | 
| 433 | 433 | return; | 
| 434 | 434 | } | 
| @@ -52,14 +52,14 @@ | ||
| 52 | 52 |      { | 
| 53 | 53 | $data = JSON::decode($message->getBody()); | 
| 54 | 54 | |
| 55 | -        if (! isset($data['jobId'])) { | |
| 55 | +        if (!isset($data['jobId'])) { | |
| 56 | 56 |              $this->logger->critical('Got invalid message'); | 
| 57 | 57 | |
| 58 | 58 | return self::REJECT; | 
| 59 | 59 | } | 
| 60 | 60 | |
| 61 | 61 | $job = $this->jobStorage->findJobById($data['jobId']); | 
| 62 | -        if (! $job) { | |
| 62 | +        if (!$job) { | |
| 63 | 63 |              $this->logger->critical(sprintf('Job was not found. id: "%s"', $data['jobId'])); | 
| 64 | 64 | |
| 65 | 65 | return self::REJECT; | 
| @@ -40,7 +40,7 @@ discard block | ||
| 40 | 40 | 'queue' => 'queue', | 
| 41 | 41 | 'priority' => 1, | 
| 42 | 42 | ]); | 
| 43 | -        $id = (int) $dbal->lastInsertId('message_queue_id_seq'); | |
| 43 | +        $id = (int)$dbal->lastInsertId('message_queue_id_seq'); | |
| 44 | 44 | |
| 45 | 45 | //guard | 
| 46 | 46 | $this->assertGreaterThan(0, $id); | 
| @@ -68,7 +68,7 @@ discard block | ||
| 68 | 68 | 'queue' => 'queue', | 
| 69 | 69 | 'priority' => 1, | 
| 70 | 70 | ]); | 
| 71 | -        $id = (int) $dbal->lastInsertId('message_queue_id_seq'); | |
| 71 | +        $id = (int)$dbal->lastInsertId('message_queue_id_seq'); | |
| 72 | 72 | |
| 73 | 73 | //guard | 
| 74 | 74 | $this->assertGreaterThan(0, $id); | 
| @@ -97,7 +97,7 @@ discard block | ||
| 97 | 97 | 'priority' => 1, | 
| 98 | 98 | 'consumer_id' => 123, | 
| 99 | 99 | ]); | 
| 100 | -        $id = (int) $dbal->lastInsertId('message_queue_id_seq'); | |
| 100 | +        $id = (int)$dbal->lastInsertId('message_queue_id_seq'); | |
| 101 | 101 | |
| 102 | 102 | //guard | 
| 103 | 103 | $this->assertGreaterThan(0, $id); | 
| @@ -121,7 +121,7 @@ discard block | ||
| 121 | 121 | $this->assertCount(1, $messages); | 
| 122 | 122 | $this->assertNotEquals($id, $messages[0]['id']); | 
| 123 | 123 | $this->assertNull($messages[0]['consumer_id']); | 
| 124 | - $this->assertTrue((bool) $messages[0]['redelivered']); | |
| 124 | + $this->assertTrue((bool)$messages[0]['redelivered']); | |
| 125 | 125 | } | 
| 126 | 126 | |
| 127 | 127 | public function testShouldReceiveMessage() | 
| @@ -134,7 +134,7 @@ discard block | ||
| 134 | 134 | 'body' => 'message', | 
| 135 | 135 | 'queue' => 'default', | 
| 136 | 136 | ]); | 
| 137 | -        $id = (int) $dbal->lastInsertId('message_queue_id_seq'); | |
| 137 | +        $id = (int)$dbal->lastInsertId('message_queue_id_seq'); | |
| 138 | 138 | |
| 139 | 139 | //guard | 
| 140 | 140 | $this->assertGreaterThan(0, $id); | 
| @@ -159,13 +159,13 @@ discard block | ||
| 159 | 159 | 'priority' => 5, | 
| 160 | 160 | 'queue' => 'default', | 
| 161 | 161 | ]); | 
| 162 | -        $id1 = (int) $dbal->lastInsertId('message_queue_id_seq'); | |
| 162 | +        $id1 = (int)$dbal->lastInsertId('message_queue_id_seq'); | |
| 163 | 163 | |
| 164 | 164 |          $dbal->insert('message_queue', [ | 
| 165 | 165 | 'priority' => 10, | 
| 166 | 166 | 'queue' => 'default', | 
| 167 | 167 | ]); | 
| 168 | -        $id2 = (int) $dbal->lastInsertId('message_queue_id_seq'); | |
| 168 | +        $id2 = (int)$dbal->lastInsertId('message_queue_id_seq'); | |
| 169 | 169 | |
| 170 | 170 | //guard | 
| 171 | 171 | $this->assertGreaterThan(0, $id1); | 
| @@ -196,13 +196,13 @@ discard block | ||
| 196 | 196 | 'priority' => 5, | 
| 197 | 197 | 'queue' => 'default', | 
| 198 | 198 | ]); | 
| 199 | -        $id1 = (int) $dbal->lastInsertId('message_queue_id_seq'); | |
| 199 | +        $id1 = (int)$dbal->lastInsertId('message_queue_id_seq'); | |
| 200 | 200 | |
| 201 | 201 |          $dbal->insert('message_queue', [ | 
| 202 | 202 | 'priority' => 5, | 
| 203 | 203 | 'queue' => 'default', | 
| 204 | 204 | ]); | 
| 205 | -        $id2 = (int) $dbal->lastInsertId('message_queue_id_seq'); | |
| 205 | +        $id2 = (int)$dbal->lastInsertId('message_queue_id_seq'); | |
| 206 | 206 | |
| 207 | 207 | //guard | 
| 208 | 208 | $this->assertGreaterThan(0, $id1); | 
| @@ -234,7 +234,7 @@ discard block | ||
| 234 | 234 | 'queue' => 'default', | 
| 235 | 235 | 'priority' => 1, | 
| 236 | 236 | ]); | 
| 237 | -        $id = (int) $dbal->lastInsertId('message_queue_id_seq'); | |
| 237 | +        $id = (int)$dbal->lastInsertId('message_queue_id_seq'); | |
| 238 | 238 | |
| 239 | 239 | //guard | 
| 240 | 240 | $this->assertGreaterThan(0, $id); | 
| @@ -258,7 +258,7 @@ discard block | ||
| 258 | 258 | 'queue' => 'default', | 
| 259 | 259 | 'priority' => 1, | 
| 260 | 260 | ]); | 
| 261 | -        $id = (int) $dbal->lastInsertId('message_queue_id_seq'); | |
| 261 | +        $id = (int)$dbal->lastInsertId('message_queue_id_seq'); | |
| 262 | 262 | |
| 263 | 263 | //guard | 
| 264 | 264 | $this->assertGreaterThan(0, $id); |