| @@ -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 | } |