@@ -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' => [ |