bimsonz / rabbitmq

src/ConnectionFactory.php

Braces +1 added lines, -2 removed lines

@@ -74,8 +74,7 @@
           $credentials['ssl'],
           $credentials['options']
         );
-      }
-      else {
+      } else {
         $connection = new AMQPStreamConnection(
           $credentials['host'],
           $credentials['port'],

src/Controller/ServerPropertiesController.php

Braces +1 added lines, -2 removed lines

@@ -27,8 +27,7 @@
     try {
       /** @var \Drupal\rabbitmq\Queue\Queue $backend */
       $backend = \Drupal::queue('queue.rabbitmq');
-    }
-    catch (\ErrorException $e) {
+    } catch (\ErrorException $e) {
       $build = [
         '#markup' => $this->t('<h2>Error</h2><p>Could not access the queue. Check the <a href=":url">status page</a>.</p>', [
           ':url' => Url::fromRoute('system.status')->toString(),

src/Consumer.php

Braces +10 added lines, -20 removed lines

@@ -144,8 +144,7 @@ 
   public function decode($data) {
     if (isset($this->decoder)) {
       return $this->decoder($data);
-    }
-    else {
+    } else {
       return json_decode($data, TRUE);
     }
   }
@@ -177,8 +176,7 @@ 
     if ($maxIterations > 0) {
       $readyMessage = "RabbitMQ worker ready to receive up to @count messages.";
       $readyArgs = ['@count' => $maxIterations];
-    }
-    else {
+    } else {
       $readyMessage = "RabbitMQ worker ready to receive an unlimited number of messages.";
       $readyArgs = [];
     }
@@ -261,15 +259,12 @@ 
           }
         }
         $this->stopListening();
-      }
-      catch (AMQPIOWaitException $e) {
+      } catch (AMQPIOWaitException $e) {
         $this->stopListening();
         $channel->close();
-      }
-      catch (AMQPTimeoutException $e) {
+      } catch (AMQPTimeoutException $e) {
         $this->startListening();
-      }
-      catch (Exception $e) {
+      } catch (Exception $e) {
         throw new Exception('Could not obtain channel for queue.', 0, $e);
       }
     }
@@ -304,8 +299,7 @@ 
     $timeout = $this->getOption(self::OPTION_TIMEOUT);
     if (!empty($timeout)) {
       pcntl_signal(SIGALRM, [$this, 'onTimeout']);
-    }
-    else {
+    } else {
       $timeout = 0;
     }
 
@@ -317,8 +311,7 @@ 
         pcntl_alarm($timeout);
         $item = $queue->claimItem();
         pcntl_alarm(0);
-      }
-      else {
+      } else {
         $item = $queue->claimItem();
       }
 
@@ -335,8 +328,7 @@ 
         // Only loop if the current continuous wait did not exceed timeout.
         if ($currentTime > $startTime + $timeout) {
           break;
-        }
-        else {
+        } else {
           continue;
         }
       }
@@ -427,8 +419,7 @@ 
           '@id' => $item->id,
           '@queue' => $queueName,
         ]);
-      }
-      catch (Exception $e) {
+      } catch (Exception $e) {
         watchdog_exception('rabbitmq', $e);
         $msg->delivery_info['channel']->basic_reject($msg->delivery_info['delivery_tag'],
           TRUE);
@@ -563,8 +554,7 @@ 
     if (!extension_loaded(static::EXTENSION_PCNTL)) {
       $req[$key]['description'] = t('Extension <a href=":ext">PCNTL</a> not present in PHP. Option  %option is not available in the RabbitMQ consumer.', $options);
       $req[$key]['severity'] = REQUIREMENT_WARNING;
-    }
-    else {
+    } else {
       $req[$key]['description'] = t('Extension <a href=":ext">PCNTL</a> is present in PHP. Option   %option is available in the RabbitMQ consumer.', $options);
       $req[$key]['severity'] = REQUIREMENT_OK;
     }

src/Queue/QueueBase.php

Braces +1 added lines, -2 removed lines

@@ -170,8 +170,7 @@
           $actualOptions['arguments'] ?? NULL,
           $actualOptions['ticket'] ?? NULL
         );
-      }
-      catch (AMQPProtocolChannelException $e) {
+      } catch (AMQPProtocolChannelException $e) {
         return NULL;
       }
 

src/Queue/Queue.php

Braces +1 added lines, -2 removed lines

@@ -49,8 +49,7 @@
       $channel->basic_publish($item, $exchange, $routing_key);
       $this->logger->debug('Item sent to queue %queue', $logger_args);
       $result = TRUE;
-    }
-    catch (\Exception $e) {
+    } catch (\Exception $e) {
       $this->logger->error('Failed to send item to queue %queue: @message', $logger_args + [
         '@message' => $e->getMessage(),
       ]);

rabbitmq.drush.inc

Braces +3 added lines, -6 removed lines

@@ -116,14 +116,11 @@
   try {
     $consumer->logStart();
     $consumer->consumeQueueApi($queueName);
-  }
-  catch (InvalidWorkerException $e) {
+  } catch (InvalidWorkerException $e) {
     return drush_set_error(dt("Worker for queue @name does not implement the worker interface.", $queueArgs));
-  }
-  catch (RabbitMqInvalidArgumentException $e) {
+  } catch (RabbitMqInvalidArgumentException $e) {
     return drush_set_error($e->getMessage());
-  }
-  catch (RabbitMqException $e) {
+  } catch (RabbitMqException $e) {
     return drush_set_error(dt("Could not obtain channel for queue.", $queueArgs));
   }