@@ -246,14 +246,14 @@ discard block |
||
246 | 246 | { |
247 | 247 | $this->amqpChannel->expects($this->any()) |
248 | 248 | ->method('basic_reject') |
249 | - ->will($this->returnCallback(function ($delivery_tag, $requeue) use ($expectedMethod, $expectedRequeue) { |
|
249 | + ->will($this->returnCallback(function($delivery_tag, $requeue) use ($expectedMethod, $expectedRequeue) { |
|
250 | 250 | Assert::assertSame($expectedMethod, 'basic_reject'); // Check if this function should be called. |
251 | 251 | Assert::assertSame($requeue, $expectedRequeue); // Check if the message should be requeued. |
252 | 252 | })); |
253 | 253 | |
254 | 254 | $this->amqpChannel->expects($this->any()) |
255 | 255 | ->method('basic_ack') |
256 | - ->will($this->returnCallback(function ($delivery_tag) use ($expectedMethod) { |
|
256 | + ->will($this->returnCallback(function($delivery_tag) use ($expectedMethod) { |
|
257 | 257 | Assert::assertSame($expectedMethod, 'basic_ack'); // Check if this function should be called. |
258 | 258 | })); |
259 | 259 | } |
@@ -266,7 +266,7 @@ discard block |
||
266 | 266 | */ |
267 | 267 | private function prepareCallback($processFlag) |
268 | 268 | { |
269 | - return function ($msg) use (&$lastQueue, $processFlag) { |
|
269 | + return function($msg) use (&$lastQueue, $processFlag) { |
|
270 | 270 | return $processFlag; |
271 | 271 | }; |
272 | 272 | } |