xervice / rabbitmq

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);
+    public function declare(RabbitMqQueueDataProvider$queueDataProvider);
 
     /**
      * @param \DataProvider\RabbitMqQueueBindDataProvider $bindDataProvider

src/Xervice/RabbitMQ/Core/ExchangeProviderInterface.php

Spacing +1 added lines, -1 removed lines

@@ -15,5 +15,5 @@
      * @param bool $internal
      * @param bool $nowait
      */
-    public function declare(RabbitMqExchangeDataProvider $exchangeDataProvider);
+    public function declare(RabbitMqExchangeDataProvider$exchangeDataProvider);
 }
\ No newline at end of file

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)
+    public function declare(RabbitMqExchangeDataProvider$exchangeDataProvider)
     {
         $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)
+    public function declare(RabbitMqQueueDataProvider$queueDataProvider)
     {
         $this->channel->queue_declare(
             $queueDataProvider->getName(),

src/Xervice/RabbitMQ/RabbitMQDependencyProvider.php

Spacing +3 added lines, -3 removed lines

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

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

Spacing +1 added lines, -1 removed lines

@@ -47,7 +47,7 @@
 
     public function consumeQueries(ListenerInterface $listener)
     {
-        $this->channel->basic_qos(null, $listener->getChunkSize(),  null);
+        $this->channel->basic_qos(null, $listener->getChunkSize(), null);
         $this->channel->basic_consume(
             $listener->getQueueName(),
             $this->config->getTag(),