fix Router

Domraider · Jul 28, 2017 · ce7dfd8 · ce7dfd8
1 parent a79f4b7
commit ce7dfd8
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/composer.json b/composer.json
@@ -1,7 +1,7 @@
 {
   "name": "domraider/rxnet",
   "description": "Rx connector for PHP",
-  "version": "0.6.8",
+  "version": "0.6.9",
   "keywords": [
     "rabbit",
     "queue",

diff --git a/src/Rxnet/Routing/Router.php b/src/Rxnet/Routing/Router.php
@@ -113,7 +113,7 @@ public function onNext($value)
                 $labels = array_merge($labels, $vars);
                 $value->setLabels($labels);
                 $subject->onNext($value);
-                $subject->subscribe($value);
+
                 return;
             }
         }