Merge pull request #1 from tochka-developers/fix-failover

fix failover

.gitignore

@@ -1,2 +1,3 @@
 nbproject
-vendor
+vendor
+.idea

README.md

@@ -1,15 +1,22 @@
 # Stomp protocol utils
+
 Набор классов-утилит для взаимодействия с брокетами сообщений (ActiveMQ, RabbitMQ, ZeroMQ и т.д.) по протоколу [Stomp](https://stomp.github.io/).
 Пакет решает две наиболее распространенные задачи:
  - Отправка сообщения в очередь;
  - Получение сообщений из очеред в режиме демона.
 Логирование можно осуществлять путем подключения любого PSR-совместимого логгера.
+
+## Requirements
+php 7.x
+
 ## Установка
 Для установки пакета с использованием composer:
-```
+```bash
 composer require stomp-utils
 ```
+
 ## Использование
+
 ### Отправка сообщения в очередь
 ```Publisher::send(string $destination, string $body[, array $headers][, string $transactionId])``` - отправляет сообщение в очередь.
 Параметры:

src/StompClient.php

@@ -1,17 +1,14 @@
 <?php
 
-/**
- * @created     28.06.2017
- */
 namespace Tochka\Integration\Stomp;
 
 use \Stomp;
 use \StompException;
 use Tochka\Integration\Stomp\Exception\StompClientException;
 
 /**
- *
- * @author Sergey Ivanov(ivanov@tochka.com)
+ * Class StompClient
+ * @package Tochka\Integration\Stomp
  */
 class StompClient
 {
@@ -40,21 +37,20 @@ public function __construct(string $connectionString, string $login, string $pw)
 
         $pattern = "|^(([a-zA-Z0-9]+)://)+\(*([a-zA-Z0-9\.:/i,-_]+)\)*$|i";
         if (preg_match($pattern, $connectionString, $matches)) {
-            $scheme = $matches[2];
-            $hostsPart = $matches[3];
 
-            if ($scheme != 'failover') {
+            list(, , $scheme, $hostsPart) = $matches;
+
+            if ($scheme !== 'failover') {
                 $hosts[] = $hostsPart;
             } else {
-                $urls = explode(',', $hosts);
-                foreach ($urls as $url) {
-                    $hosts[] = $urls;
+                foreach (explode(',', $hostsPart) as $url) {
+                    $hosts[] = $url;
                 }
             }
         }
 
         if (empty($hosts)) {
-            throw new StompClientException("Bad Broker URL {$connectionString}. Check used scheme!");
+            throw new StompClientException('Bad Broker URL ' . $connectionString . 'Check used scheme!');
         }
 
         $this->hosts = $hosts;
@@ -72,10 +68,11 @@ public function __destruct()
 
     /**
      * @return Stomp
+     * @throws StompClientException
      */
-    public function getConnection()
+    public function getConnection(): \Stomp
     {
-        if (is_null($this->stomp)) {
+        if (null === $this->stomp) {
             $this->newConnection();
         }
 
@@ -134,4 +131,4 @@ private function connect($url, $login, $pw)
 
         return null;
     }
-}
+}