noitran / lumen-horizon-rabbitmq

src/HorizonServiceProvider.php

Spacing +1 added lines, -1 removed lines

@@ -44,7 +44,7 @@
     {
         $queue = $this->app['queue'];
 
-        $queue->addConnector('rabbitmq', function () {
+        $queue->addConnector('rabbitmq', function() {
             return new RabbitMQConnector($this->app['events']);
         });
     }

src/Connectors/RabbitMQConnector.php

Spacing +1 added lines, -1 removed lines

@@ -77,7 +77,7 @@
         /** @var AmqpContext $context */
         $context = $factory->createContext();
 
-        $this->dispatcher->listen(WorkerStopping::class, function () use ($context): void {
+        $this->dispatcher->listen(WorkerStopping::class, function() use ($context): void {
             $context->close();
         });
 

src/RabbitMQQueue.php

Spacing +3 added lines, -3 removed lines

@@ -50,7 +50,7 @@ 
     {
         $payload = (new JobPayload($payload))->prepare($this->lastPushed)->value;
 
-        return tap(parent::pushRaw($payload, $queue, $options), function () use ($queue, $payload): void {
+        return tap(parent::pushRaw($payload, $queue, $options), function() use ($queue, $payload): void {
             $this->event($this->getQueue($queue), new JobPushed($payload));
         });
     }
@@ -66,7 +66,7 @@ 
             'delay' => $this->secondsUntil($delay),
         ];
 
-        return tap(parent::pushRaw($payload, $queue, $options), function () use ($payload, $queue): void {
+        return tap(parent::pushRaw($payload, $queue, $options), function() use ($payload, $queue): void {
             $this->event($this->getQueue($queue), new JobPushed($payload));
         });
     }
@@ -94,7 +94,7 @@ 
      */
     public function pop($queue = null)
     {
-        return tap($this->popRaw($queue), function ($result) use ($queue): void {
+        return tap($this->popRaw($queue), function($result) use ($queue): void {
             if ($result) {
                 $this->event($this->getQueue($queue), new JobReserved($result->getRawBody()));
             }

tests/RabbitMQQueueTest.php

Spacing +1 added lines, -1 removed lines

@@ -21,7 +21,7 @@
             ->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());