fix CI issues.

Author: makasim

src/Queue/Connectors/RabbitMQConnector.php

@@ -65,7 +65,7 @@ public function connect(array $config): Queue
 
         $context = $factory->createContext();
 
-        $this->dispatcher->listen(WorkerStopping::class, function () use($context) {
+        $this->dispatcher->listen(WorkerStopping::class, function () use ($context) {
             $context->close();
         });
 

tests/Queue/RabbitMQQueueTest.php

@@ -121,7 +121,7 @@ public function testShouldSendExpectedMessageOnPushRaw()
             ->expects($this->once())
             ->method('send')
             ->with($this->identicalTo($topic), $this->isInstanceOf(AmqpMessage::class))
-            ->willReturnCallback(function($actualTopic, AmqpMessage $message) use ($expectedQueueName, $expectedBody, $topic) {
+            ->willReturnCallback(function ($actualTopic, AmqpMessage $message) use ($expectedQueueName, $expectedBody, $topic) {
                 $this->assertSame($topic, $actualTopic);
                 $this->assertSame($expectedBody, $message->getBody());
                 $this->assertSame($expectedQueueName, $message->getRoutingKey());
@@ -178,7 +178,7 @@ public function testShouldSetAttemptCountHeaderIfNotNull()
             ->expects($this->once())
             ->method('send')
             ->with($this->identicalTo($topic), $this->isInstanceOf(AmqpMessage::class))
-            ->willReturnCallback(function($actualTopic, AmqpMessage $message) use ($expectedAttempts) {
+            ->willReturnCallback(function ($actualTopic, AmqpMessage $message) use ($expectedAttempts) {
                 $this->assertSame($expectedAttempts, $message->getProperty(RabbitMQQueue::ATTEMPT_COUNT_HEADERS_KEY));
             })
         ;
@@ -270,7 +270,7 @@ public function testShouldLogExceptionOnPushRaw()
         $producer
             ->expects($this->once())
             ->method('send')
-            ->willReturnCallback(function() {
+            ->willReturnCallback(function () {
                 throw new \LogicException('Something went wrong while sending a message');
             })
         ;
@@ -398,7 +398,7 @@ public function testShouldLogExceptionOnPop()
         $consumer
             ->expects($this->once())
             ->method('receiveNoWait')
-            ->willReturnCallback(function() {
+            ->willReturnCallback(function () {
                 throw new \LogicException('Something went wrong while receiving a message');
             })
         ;