Added failswitch parameter for subscribe

hprose · Aug 24, 2016 · 6fe074c · 6fe074c
1 parent 9576431
commit 6fe074c
Showing 1 changed file with 7 additions and 7 deletions.
diff --git a/src/Hprose/Client.php b/src/Hprose/Client.php
@@ -14,7 +14,7 @@
  *                                                        *
  * hprose client class for php 5.3+                       *
  *                                                        *
- * LastModified: Aug 8, 2016                              *
+ * LastModified: Aug 24, 2016                             *
  * Author: Ma Bingyao <[email protected]>                  *
  *                                                        *
 \**********************************************************/
@@ -614,9 +614,9 @@ public function getId() {
             $this->topics[$name] = array();
         }
     }
-    // subscribe($name, $callback, $timeout)
-    // subscribe($name, $id, $callback, $timeout)
-    public function subscribe($name, $id = null, $callback = null, $timeout = null) {
+    // subscribe($name, $callback, $timeout, $failswitch)
+    // subscribe($name, $id, $callback, $timeout, $failswitch)
+    public function subscribe($name, $id = null, $callback = null, $timeout = null, $failswitch = false) {
         $self = $this;
         if (!is_string($name)) {
             throw new TypeError('topic name must be a string');
@@ -633,8 +633,8 @@ public function subscribe($name, $id = null, $callback = null, $timeout = null)
             if ($this->id == null) {
                 $this->id = $this->autoId();
             }
-            $this->id->then(function($id) use ($self, $name, $callback, $timeout) {
-                $self->subscribe($name, $id, $callback, $timeout);
+            $this->id->then(function($id) use ($self, $name, $callback, $timeout, $failswitch) {
+                $self->subscribe($name, $id, $callback, $timeout, $failswitch);
             });
             return;
         }
@@ -644,7 +644,7 @@ public function subscribe($name, $id = null, $callback = null, $timeout = null)
             $topic = new stdClass();
             $settings = new InvokeSettings(array(
                 'idempotent' => true,
-                'failswitch' => false,
+                'failswitch' => $failswitch,
                 'timeout' => $timeout
             ));
             $cb = function() use ($self, &$cb, $topic, $name, $id, $settings) {