Adds connection manager

src/nsqphp/Connection/ConnectionManager.php

@@ -0,0 +1,19 @@
+<?php
+
+namespace nsqphp\Connection;
+
+class ConnectionManager extends ConnectionPool
+{
+    private function __construct()
+    {
+    }
+
+    public static function getInstance()
+    {
+        static $instance;
+        if (!$instance) {
+            $instance = new self;
+        }
+        return $instance;
+    }
+}

src/nsqphp/nsqphp.php

@@ -219,21 +219,26 @@ public function publishTo($hosts, $cl = NULL)
         if (!is_array($hosts)) {
             $hosts = explode(',', $hosts);
         }
+        $cm = Connection\ConnectionManager::getInstance();
         foreach ($hosts as $h) {
             if (strpos($h, ':') === FALSE) {
                 $h .= ':4150';
             }
 
             $parts = explode(':', $h);
-            $conn = new Connection\Connection(
-                    $parts[0],
-                    isset($parts[1]) ? $parts[1] : NULL,
-                    $this->connectionTimeout,
-                    $this->readWriteTimeout,
-                    $this->readWaitTimeout,
-                    FALSE,      // blocking
-                    array($this, 'connectionCallback')
-                    );
+            $conn = $cm->find($h);
+            if (!$conn) {
+                $conn = new Connection\Connection(
+                        $parts[0],
+                        isset($parts[1]) ? $parts[1] : NULL,
+                        $this->connectionTimeout,
+                        $this->readWriteTimeout,
+                        $this->readWaitTimeout,
+                        FALSE,      // blocking
+                        array($this, 'connectionCallback')
+                        );
+                $cm->add($conn);
+            }
             $this->pubConnectionPool->add($conn);
         }