修改一处参数错误

xutl · Sep 1, 2018 · 161256b · 161256b
1 parent 94f1849
commit 161256b
Showing 1 changed file with 11 additions and 1 deletion.
diff --git a/src/MNSFlushCommand.php b/src/MNSFlushCommand.php
@@ -43,7 +43,7 @@ public function handle()
         if (!$queue) {
             $queue = $config['queue'];
         }
-        $client = new Client($config['endpoint'], $config['key'], $config['secret']);
+        $client = new Client($this->getEndpoint($config), $config['access_id'], $config['access_key'], $config['security_token']);
         $queue = $client->getQueueRef($queue);
         $hasMessage = true;
         while ($hasMessage) {
@@ -88,6 +88,16 @@ protected function getArguments()
         ];
     }
 
+    /**
+     * @param array $config
+     *
+     * @return mixed
+     */
+    protected function getEndpoint(array $config)
+    {
+        return str_replace('(s)', 's', $config['endpoint']);
+    }
+
     /**
      * Get the console command arguments.
      *