fix issue 404

freyo · May 7, 2019 · eadff52 · eadff52
1 parent 9003b53
commit eadff52
Showing 1 changed file with 10 additions and 3 deletions.
diff --git a/src/Queue/Driver/CMQClient.php b/src/Queue/Driver/CMQClient.php
@@ -20,16 +20,23 @@ public function __construct($host, $secretId, $secretKey, $version = 'SDK_PHP_1.
         $this->version = $version;
         $this->method = $method;
         $this->sign_method = 'HmacSHA1';
-        $this->http = new CMQHttp($this->host);
+        $this->http = new CMQHttp($host);
     }
 
     protected function process_host($host)
     {
-        if (strpos($host, 'http://') === 0 || strpos($host, 'https://') === 0) {
-            $this->host = rtrim($host, '/');
+        if (strpos($host, 'http://') === 0) {
+            $_host = substr($host, 7, strlen($host) - 7);
+        } elseif (strpos($host, 'https://') === 0) {
+            $_host = substr($host, 8, strlen($host) - 8);
         } else {
             throw new CMQClientParameterException('Only support http(s) prototol. Invalid endpoint:'.$host);
         }
+        if ($_host[strlen($_host) - 1] == '/') {
+            $this->host = substr($_host, 0, strlen($_host) - 1);
+        } else {
+            $this->host = $_host;
+        }
     }
 
     public function set_sign_method($sign_method = 'sha1')