- Ability to resubscribe on reconnect

Author: irekk-wf

README.md

@@ -30,7 +30,7 @@ Now let's tell composer about our project's dependancies, in this case, PHPNats.
 ```
 {
   "require": {
-    "workfront/nats": "2.2.0"
+    "workfront/nats": "2.2.1"
   }
 }
 ```

composer.json

@@ -4,7 +4,7 @@
     "type": "library",
     "minimum-stability": "dev",
     "license": "MIT",
-    "version": "2.2.0",
+    "version": "2.2.1",
     "require": {
         "php": "^7.1"
     },

src/Nats/Connection.php

@@ -488,6 +488,7 @@ public function subscribe($subject, \Closure $callback)
         $msg = 'SUB '.$subject.' '.$sid;
         $this->send($msg);
         $this->subscriptions[$sid] = $callback;
+        $this->registeredSubscriptions[$subject] = [null, $callback];
         return $sid;
     }
 
@@ -505,6 +506,7 @@ public function queueSubscribe($subject, $queue, \Closure $callback)
         $msg = 'SUB '.$subject.' '.$queue.' '.$sid;
         $this->send($msg);
         $this->subscriptions[$sid] = $callback;
+        $this->registeredSubscriptions[$subject] = [$queue, $callback];
         return $sid;
     }
 
@@ -596,16 +598,23 @@ public function wait($quantity = 0)
      */
     public function reconnect($resubscribe = false)
     {
+        $sids = [];
         $this->reconnects += 1;
         $this->close();
         $this->connect($this->timeout);
         if ($resubscribe) {
             if ($this->isConnected()) {
-                foreach ($this->registeredSubscriptions as $subject => $callback) {
-                    $this->subscribe($subject, $callback);
+                foreach ($this->registeredSubscriptions as $subject => $info) {
+                    if ($info[0] === null) {
+                        $sids[$subject] = $this->subscribe($subject, $info[1]);
+                    }
+                    else {
+                        $sids[$subject] = $this->queueSubscribe($subject, $info[0], $info[1]);
+                    }
                 }
             }
         }
+        return $sids;
     }
 
     /**