xervice / rabbitmq

src/Xervice/RabbitMQ/RabbitMQDependencyProvider.php

Spacing +3 added lines, -3 removed lines

@@ -61,7 +61,7 @@ 
      */
     private function createExchangeCollection(DependencyContainerInterface $container): DependencyContainerInterface
     {
-        $container[self::RABBITMQ_EXCHANGES] = function (DependencyContainerInterface $container) {
+        $container[self::RABBITMQ_EXCHANGES] = function(DependencyContainerInterface $container) {
             return new ExchangeCollection(
                 $this->getExchanges()
             );
@@ -77,7 +77,7 @@ 
      */
     private function createQueueCollection(DependencyContainerInterface $container): DependencyContainerInterface
     {
-        $container[self::RABBITMQ_QUEUES] = function (DependencyContainerInterface $container) {
+        $container[self::RABBITMQ_QUEUES] = function(DependencyContainerInterface $container) {
             return new QueueCollection(
                 $this->getQueues()
             );
@@ -93,7 +93,7 @@ 
      */
     private function createListenerCollection(DependencyContainerInterface $container): DependencyContainerInterface
     {
-        $container[self::RABBITMQ_LISTENER] = function (DependencyContainerInterface $container) {
+        $container[self::RABBITMQ_LISTENER] = function(DependencyContainerInterface $container) {
             return new ListenerCollection(
                 $this->getListener()
             );

src/Xervice/RabbitMQ/Business/Model/Message/MessageProvider.php

Spacing +1 added lines, -1 removed lines

@@ -60,7 +60,7 @@
     private function createMessage(RabbitMqMessageDataProvider $messageDataDataProvider): AMQPMessage
     {
         return new AMQPMessage(
-            (string)json_encode(
+            (string) json_encode(
                 $messageDataDataProvider->toArray()
             ),
             $messageDataDataProvider->getProperties()

src/Xervice/RabbitMQ/Business/Model/Core/ExchangeProviderInterface.php

Spacing +1 added lines, -1 removed lines

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

src/Xervice/RabbitMQ/Business/Model/Core/ExchangeProvider.php

Spacing +1 added lines, -1 removed lines

@@ -31,7 +31,7 @@
     /**
      * @param \DataProvider\RabbitMqExchangeDataProvider $exchangeDataProvider
      */
-    public function declare(RabbitMqExchangeDataProvider $exchangeDataProvider): void
+    public function declare(RabbitMqExchangeDataProvider$exchangeDataProvider): void
     {
         $this->channel->exchange_declare(
             $exchangeDataProvider->getName(),

src/Xervice/RabbitMQ/Business/Model/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/Business/Model/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/Communication/Console/Command/WorkerCommand.php

Spacing +1 added lines, -1 removed lines

@@ -23,7 +23,7 @@
         $this
             ->setName('queue:worker:run')
             ->addOption('loop', 'l', InputOption::VALUE_NONE, 'Endless loop')
-            ->addOption('runtime', 't', InputOption::VALUE_REQUIRED, 'How long running this command',60);
+            ->addOption('runtime', 't', InputOption::VALUE_REQUIRED, 'How long running this command', 60);
     }
 
     /**