$queue = 'export_pali_chapter';

app/Console/Commands/MqExportPaliChapter.php

@@ -40,16 +40,16 @@ class MqExportPaliChapter extends Command
     public function handle()
     {
         $exchange = 'router';
-        $queue = 'export';
+        $queue = 'export_pali_chapter';
         $this->info(" [*] Waiting for {$queue}. To exit press CTRL+C");
-        Log::debug("mq:progress start.");
+        Log::debug("mq:export_pali_chapter start.");
         Mq::worker($exchange,$queue,function ($message){
             $data = [
                         'book'=>$message->book,
                         'para'=>$message->para,
                         'channel'=>$message->channel,
                         '--format'=>$message->format,
-                        'filename'=>$message->filename,
+                        'query_id'=>$message->queryId,
                     ];
             if(isset($message->origin) && is_string($message->origin)){
                 $data['--origin'] = $message->origin;
@@ -57,12 +57,15 @@ class MqExportPaliChapter extends Command
             if(isset($message->translation) && is_string($message->translation)){
                 $data['--translation'] = $message->translation;
             }
+            if(isset($message->token) && is_string($message->token)){
+                $data['--token'] = $message->token;
+            }
             $ok = $this->call('export:chapter',$data);
             if($ok !== 0){
-                Log::error('mq:progress upgrade:progress fail',$data);
+                Log::error('mq:export.pali.chapter upgrade:progress fail',$data);
             }else{
                 $this->info("Received book=".$message->book.' result='.$ok);
-                Log::debug("mq:export: done ",$data);
+                Log::debug("mq:export.pali.chapter done ",$data);
                 return $ok;
             }
         });