@@ -80,7 +80,7 @@ |
||
| 80 | 80 | $results |
| 81 | 81 | ->expects($this->atLeastOnce()) |
| 82 | 82 | ->method('current') |
| 83 | - ->willReturnCallback(function () { |
|
| 83 | + ->willReturnCallback(function() { |
|
| 84 | 84 | $this->methodCalls++; |
| 85 | 85 | return $this->methodCalls < 7 ? new ResultRecord(new User()) : null; |
| 86 | 86 | }); |
@@ -192,7 +192,7 @@ |
||
| 192 | 192 | { |
| 193 | 193 | $dataForSerialization = [$this->id, $this->role, $this->label]; |
| 194 | 194 | if (property_exists($this, 'organization')) { |
| 195 | - $dataForSerialization[] = is_object($this->organization) ? clone $this->organization : $this->organization; |
|
| 195 | + $dataForSerialization[] = is_object($this->organization) ? clone $this->organization : $this->organization; |
|
| 196 | 196 | } |
| 197 | 197 | |
| 198 | 198 | return serialize($dataForSerialization); |
@@ -90,11 +90,11 @@ discard block |
||
| 90 | 90 | |
| 91 | 91 | self::assertEquals( |
| 92 | 92 | 'oro_message_queue.transport.default.connection', |
| 93 | - (string) $container->getAlias('oro_message_queue.transport.connection') |
|
| 93 | + (string)$container->getAlias('oro_message_queue.transport.connection') |
|
| 94 | 94 | ); |
| 95 | 95 | self::assertEquals( |
| 96 | 96 | 'oro_message_queue.transport.null.connection', |
| 97 | - (string) $container->getAlias('oro_message_queue.transport.default.connection') |
|
| 97 | + (string)$container->getAlias('oro_message_queue.transport.default.connection') |
|
| 98 | 98 | ); |
| 99 | 99 | } |
| 100 | 100 | |
@@ -136,11 +136,11 @@ discard block |
||
| 136 | 136 | |
| 137 | 137 | self::assertEquals( |
| 138 | 138 | 'oro_message_queue.transport.default.connection', |
| 139 | - (string) $container->getAlias('oro_message_queue.transport.connection') |
|
| 139 | + (string)$container->getAlias('oro_message_queue.transport.connection') |
|
| 140 | 140 | ); |
| 141 | 141 | self::assertEquals( |
| 142 | 142 | 'oro_message_queue.transport.foo.connection', |
| 143 | - (string) $container->getAlias('oro_message_queue.transport.default.connection') |
|
| 143 | + (string)$container->getAlias('oro_message_queue.transport.default.connection') |
|
| 144 | 144 | ); |
| 145 | 145 | } |
| 146 | 146 | |
@@ -233,7 +233,7 @@ discard block |
||
| 233 | 233 | self::assertInstanceOf(Reference::class, $messageProducer->getArgument(0)); |
| 234 | 234 | self::assertEquals( |
| 235 | 235 | 'oro_message_queue.client.traceable_message_producer.inner', |
| 236 | - (string) $messageProducer->getArgument(0) |
|
| 236 | + (string)$messageProducer->getArgument(0) |
|
| 237 | 237 | ); |
| 238 | 238 | } |
| 239 | 239 | |
@@ -153,7 +153,7 @@ |
||
| 153 | 153 | ] |
| 154 | 154 | ]]); |
| 155 | 155 | |
| 156 | - $pidDir = rtrim(sys_get_temp_dir(), DIRECTORY_SEPARATOR).DIRECTORY_SEPARATOR.'oro-message-queue'; |
|
| 156 | + $pidDir = rtrim(sys_get_temp_dir(), DIRECTORY_SEPARATOR) . DIRECTORY_SEPARATOR . 'oro-message-queue'; |
|
| 157 | 157 | |
| 158 | 158 | $this->assertEquals([ |
| 159 | 159 | 'transport' => [ |
@@ -16,7 +16,7 @@ |
||
| 16 | 16 | protected function setUp() |
| 17 | 17 | { |
| 18 | 18 | $this->driver = $this->createMock(StateDriverInterface::class); |
| 19 | - $this->consumerHeartbeat= new ConsumerHeartbeat($this->driver, 15); |
|
| 19 | + $this->consumerHeartbeat = new ConsumerHeartbeat($this->driver, 15); |
|
| 20 | 20 | } |
| 21 | 21 | |
| 22 | 22 | public function testTick() |
@@ -54,7 +54,7 @@ |
||
| 54 | 54 | { |
| 55 | 55 | $config = $this->processConfiguration(new Configuration($this->factories), $configs); |
| 56 | 56 | |
| 57 | - $loader = new YamlFileLoader($container, new FileLocator(__DIR__.'/../Resources/config')); |
|
| 57 | + $loader = new YamlFileLoader($container, new FileLocator(__DIR__ . '/../Resources/config')); |
|
| 58 | 58 | $loader->load('services.yml'); |
| 59 | 59 | $loader->load('log.yml'); |
| 60 | 60 | $loader->load('job.yml'); |
@@ -48,8 +48,7 @@ discard block |
||
| 48 | 48 | } elseif (is_array($params)) { |
| 49 | 49 | $processorName = empty($params['processorName']) ? $serviceId : $params['processorName']; |
| 50 | 50 | $destinationName = empty($params['destinationName']) ? |
| 51 | - Config::DEFAULT_QUEUE_NAME : |
|
| 52 | - $params['destinationName']; |
|
| 51 | + Config::DEFAULT_QUEUE_NAME : $params['destinationName']; |
|
| 53 | 52 | |
| 54 | 53 | $configs[$destinationName]['subscribers'][] = $processorName; |
| 55 | 54 | } else { |
@@ -71,8 +70,7 @@ discard block |
||
| 71 | 70 | foreach ($tagAttributes as $tagAttribute) { |
| 72 | 71 | $processorName = empty($tagAttribute['processorName']) ? $serviceId : $tagAttribute['processorName']; |
| 73 | 72 | $destinationName = empty($tagAttribute['destinationName']) ? |
| 74 | - Config::DEFAULT_QUEUE_NAME : |
|
| 75 | - $tagAttribute['destinationName']; |
|
| 73 | + Config::DEFAULT_QUEUE_NAME : $tagAttribute['destinationName']; |
|
| 76 | 74 | |
| 77 | 75 | $configs[$destinationName]['subscribers'][] = $processorName; |
| 78 | 76 | } |
@@ -48,6 +48,6 @@ |
||
| 48 | 48 | return false; |
| 49 | 49 | } |
| 50 | 50 | |
| 51 | - return !(($currentTime->getTimestamp() - $lastAliveTime->getTimestamp())/60 >= $this->updatePeriod); |
|
| 51 | + return !(($currentTime->getTimestamp() - $lastAliveTime->getTimestamp()) / 60 >= $this->updatePeriod); |
|
| 52 | 52 | } |
| 53 | 53 | } |
@@ -395,7 +395,7 @@ |
||
| 395 | 395 | 'priority' => 77, |
| 396 | 396 | 'class' => 'Old Class', |
| 397 | 397 | 'subblocks' => [] |
| 398 | - ] ; |
|
| 398 | + ]; |
|
| 399 | 399 | |
| 400 | 400 | return [ |
| 401 | 401 | 'remove not existing block' => [ |