Merge pull request repejota#53 from dfeyer/task-better-exception

TASK: Better exception handling in Connection::handleMSG

Author: repejota

src/Connection.php

@@ -353,7 +353,8 @@ private function handlePING()
      *
      * @param string $line Message command from NATS.
      *
-     * @return \Exception|void
+     * @return void
+     * @throws Exception
      * @codeCoverageIgnore
      */
     private function handleMSG($line)
@@ -374,11 +375,15 @@ private function handleMSG($line)
         $payload = $this->receive($length);
         $msg = new Message($subject, $payload, $sid, $this);
 
+        if (!isset($this->subscriptions[$sid])) {
+            throw new Exception('subscription not found');
+        }
+
         $func = $this->subscriptions[$sid];
         if (is_callable($func)) {
             $func($msg);
         } else {
-            return new \Exception('not callable');
+            throw new Exception('not callable');
         }
 
         return;

src/Exception.php

@@ -0,0 +1,10 @@
+<?php
+namespace Nats;
+
+/**
+ * Exception Class.
+ */
+class Exception extends \Exception
+{
+
+}