update

xutl · Jul 16, 2018 · 05ec81a · 05ec81a
1 parent 9ed6a9a
commit 05ec81a
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 6 deletions.
diff --git a/src/CMQFlushCommand.php b/src/CMQFlushCommand.php
@@ -7,12 +7,10 @@
 
 namespace XuTL\QCloud\Cmq\Queue;
 
-use Exception;
 use Illuminate\Console\Command;
 use Symfony\Component\Console\Input\InputArgument;
 use Symfony\Component\Console\Input\InputOption;
 use XuTL\QCloud\Cmq\Client;
-use XuTL\QCloud\Cmq\Requests\BatchReceiveMessageRequest;
 
 class CMQFlushCommand extends Command
 {
@@ -47,9 +45,7 @@ public function handle()
         $queue = $client->getQueueRef($queue);
         $hasMessage = true;
         while ($hasMessage) {
-            $request = new BatchReceiveMessageRequest();
-            $request->setNumOfMsg(16);
-            $response = $queue->batchReceiveMessage($request);
+            $response = $queue->batchReceiveMessage(16);
             $handles = [];
 
             foreach ($response->getMessages() as $message) {

diff --git a/src/CMQJob.php b/src/CMQJob.php
@@ -37,7 +37,7 @@ class CMQJob extends Job implements JobContract
      * @param \Illuminate\Container\Container $container
      * @param CMQAdapter $mns
      * @param string $queue
-     * @param \AliyunMNS\Responses\ReceiveMessageResponse $job
+     * @param ReceiveMessageResponse $job
      */
     public function __construct(Container $container, CMQAdapter $mns, $queue, ReceiveMessageResponse $job)
     {