diff --git a/src/CMQFlushCommand.php b/src/CMQFlushCommand.php
index a87aec0..42c668d 100644
--- 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
index d4cfefa..a1665ae 100644
--- 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)
     {