contamobi / CmobiRabbitmqBundle

Transport/Worker/WorkerQueueCallback.php

Spacing +1 added lines, -1 removed lines

@@ -28,7 +28,7 @@
      */
     public function toClosure()
     {
-        return function (AMQPMessage $message) {
+        return function(AMQPMessage $message) {
             $this->getQueueService()->handle($message);
 
             $message->delivery_info['channel']->basic_ack($message->delivery_info['delivery_tag']);

Connection/ConnectionFactory.php

Spacing +3 added lines, -3 removed lines

@@ -62,10 +62,10 @@
             $this->parameters['user'],
             $this->parameters['password'],
             $this->parameters['vhost'],
-            false,      // insist
+            false, // insist
             'AMQPLAIN', // login_method
-            null,       // login_response
-            'en_US',    // locale
+            null, // login_response
+            'en_US', // locale
             $this->parameters['connection_timeout'],
             $this->parameters['read_write_timeout'],
             $this->parameters['ssl_context'],

Transport/Rpc/RpcQueueCallback.php

Spacing +2 added lines, -2 removed lines

@@ -29,11 +29,11 @@
      */
     public function toClosure()
     {
-        return function (AMQPMessage $message) {
+        return function(AMQPMessage $message) {
             $response = $this->getQueueService()->handle($message);
 
             $amqpResponse = new CmobiAMQPMessage(
-                (string) $response,
+                (string)$response,
                 ['correlation_id' => $message->get('correlation_id')]
             );
 

Tests/Queue/QueueTest.php

Spacing +1 added lines, -1 removed lines

@@ -76,7 +76,7 @@
             ->disableOriginalConstructor()
             ->getMock();
         $callbackMock->method('toClosure')
-            ->willReturn(function () {});
+            ->willReturn(function() {});
 
         return $callbackMock;
     }

DependencyInjection/CmobiRabbitmqExtension.php

Spacing +1 added lines, -1 removed lines

@@ -16,7 +16,7 @@
 {
     public function load(array $configs, ContainerBuilder $container)
     {
-        $fileLocator = new FileLocator(__DIR__ . '/../Resources/config');
+        $fileLocator = new FileLocator(__DIR__.'/../Resources/config');
         $loader = new YamlFileLoader($container, $fileLocator);
         $loader->load('rabbitmq.yml');
 

Transport/Subscriber/SubscriberQueueCallback.php

Spacing +1 added lines, -1 removed lines

@@ -28,7 +28,7 @@
      */
     public function toClosure()
     {
-        return function (AMQPMessage $message) {
+        return function(AMQPMessage $message) {
             $this->getQueueService()->handle($message);
         };
     }

Queue/Queue.php

Unused Use Statements -1 removed lines

@@ -6,7 +6,6 @@
 use Cmobi\RabbitmqBundle\Connection\CmobiAMQPConnection;
 use Cmobi\RabbitmqBundle\Connection\ConnectionManager;
 use Cmobi\RabbitmqBundle\Connection\Exception\InvalidAMQPChannelException;
-use Psr\Log\LoggerInterface;
 
 class Queue implements QueueInterface
 {

Spacing +3 added lines, -3 removed lines

@@ -145,17 +145,17 @@
         do {
             try {
                 $failed = false;
-                fwrite($this->logOutput, 'start Queue::forceReconnect() - trying connect...' . PHP_EOL);
+                fwrite($this->logOutput, 'start Queue::forceReconnect() - trying connect...'.PHP_EOL);
                 $this->connection = $this->getConnectionManager()->getConnection($this->connectionName);
                 $this->channel = $this->getConnection()->channel();
                 $this->createQueue();
             } catch (\Exception $e) {
                 $failed = true;
                 sleep(3);
-                fwrite($this->errOutput, 'failed Queue::forceReconnect() - ' . $e->getMessage() . PHP_EOL);
+                fwrite($this->errOutput, 'failed Queue::forceReconnect() - '.$e->getMessage().PHP_EOL);
             }
         } while ($failed);
-        fwrite($this->logOutput, 'Queue::forceReconnect() - connected!' . PHP_EOL);
+        fwrite($this->logOutput, 'Queue::forceReconnect() - connected!'.PHP_EOL);
 
         return $this->channel;
     }

Transport/Subscriber/SubscriberBuilder.php

Spacing +1 added lines, -1 removed lines

@@ -30,7 +30,7 @@
      */
     public function buildQueue($queueName, QueueServiceInterface $queueService, QueueBagInterface $queueBag)
     {
-        if (! $queueBag instanceof SubscriberQueueBag) {
+        if (!$queueBag instanceof SubscriberQueueBag) {
             throw new \Exception('Unsupported QueueBag');
         }
         $queue = new Queue($this->getConnectionManager(), $queueBag, $this->connectionName);

Transport/Rpc/RpcServerBuilder.php

Spacing +1 added lines, -1 removed lines

@@ -30,7 +30,7 @@
      */
     public function buildQueue($queueName, QueueServiceInterface $queueService, QueueBagInterface $queueBag)
     {
-        if (! $queueBag instanceof RpcQueueBag) {
+        if (!$queueBag instanceof RpcQueueBag) {
             throw new \Exception('Unsupported QueueBag');
         }
         $queue = new Queue($this->getConnectionManager(), $queueBag, $this->connectionName);