xervice / rabbitmq

src/Xervice/RabbitMQ/Core/ExchangeProvider.php

Spacing +1 added lines, -1 removed lines

@@ -37,7 +37,7 @@
      * @param bool $internal
      * @param bool $nowait
      */
-    public function declare(RabbitMqExchangeDataProvider $exchangeDataProvider): void
+    public function declare(RabbitMqExchangeDataProvider$exchangeDataProvider): void
     {
         $this->channel->exchange_declare(
             $exchangeDataProvider->getName(),

src/Xervice/RabbitMQ/Core/QueueProvider.php

Spacing +1 added lines, -1 removed lines

@@ -28,7 +28,7 @@
     /**
      * @param \DataProvider\RabbitMqQueueDataProvider $queueDataProvider
      */
-    public function declare(RabbitMqQueueDataProvider $queueDataProvider): void
+    public function declare(RabbitMqQueueDataProvider$queueDataProvider): void
     {
         $this->channel->queue_declare(
             $queueDataProvider->getName(),

src/Xervice/RabbitMQ/Core/ExchangeProviderInterface.php

Spacing +1 added lines, -1 removed lines

@@ -15,7 +15,7 @@
      * @param bool $internal
      * @param bool $nowait
      */
-    public function declare(RabbitMqExchangeDataProvider $exchangeDataProvider): void;
+    public function declare(RabbitMqExchangeDataProvider$exchangeDataProvider): void;
 
     /**
      * @param \DataProvider\RabbitMqExchangeDataProvider $exchangeDataProvider

src/Xervice/RabbitMQ/Core/QueueProviderInterface.php

Spacing +1 added lines, -1 removed lines

@@ -10,7 +10,7 @@
     /**
      * @param \DataProvider\RabbitMqQueueDataProvider $queueDataProvider
      */
-    public function declare(RabbitMqQueueDataProvider $queueDataProvider): void;
+    public function declare(RabbitMqQueueDataProvider$queueDataProvider): void;
 
     /**
      * @param \DataProvider\RabbitMqQueueBindDataProvider $bindDataProvider

src/Xervice/RabbitMQ/Worker/Consumer/Consumer.php

Braces +1 added lines, -2 removed lines

@@ -82,8 +82,7 @@
                     1
                 );
             }
-        }
-        catch (\Exception $e) {
+        } catch (\Exception $e) {
             $finished = true;
         }
 

src/Xervice/RabbitMQ/RabbitMQDependencyProvider.php

Spacing +3 added lines, -3 removed lines

@@ -57,7 +57,7 @@ 
      */
     private function createExchangeCollection(DependencyProviderInterface $dependencyProvider): void
     {
-        $dependencyProvider[self::RABBITMQ_EXCHANGES] = function (DependencyProviderInterface $dependencyProvider) {
+        $dependencyProvider[self::RABBITMQ_EXCHANGES] = function(DependencyProviderInterface $dependencyProvider) {
             return new ExchangeCollection(
                 $this->getExchanges()
             );
@@ -69,7 +69,7 @@ 
      */
     private function createQueueCollection(DependencyProviderInterface $dependencyProvider): void
     {
-        $dependencyProvider[self::RABBITMQ_QUEUES] = function (DependencyProviderInterface $dependencyProvider) {
+        $dependencyProvider[self::RABBITMQ_QUEUES] = function(DependencyProviderInterface $dependencyProvider) {
             return new QueueCollection(
                 $this->getQueues()
             );
@@ -81,7 +81,7 @@ 
      */
     private function createListenerCollection(DependencyProviderInterface $dependencyProvider): void
     {
-        $dependencyProvider[self::RABBITMQ_LISTENER] = function (DependencyProviderInterface $dependencyProvider) {
+        $dependencyProvider[self::RABBITMQ_LISTENER] = function(DependencyProviderInterface $dependencyProvider) {
             return new ListenerCollection(
                 $this->getListener()
             );