more configurable options

Author: limenet

config/elastica-bridge.php

@@ -6,4 +6,5 @@
         'port' => env('ELASTICSEARCH_PORT', '9200'),
     ],
     'indices' => [],
+    'queue' => env('ELASTICSEARCH_QUEUE', config('queue.default')),
 ];

src/Commands/IndexCommand.php

@@ -55,13 +55,14 @@ public function handle()
 
             $this->info(sprintf('Indexing %s', $indexConfig->getName()));
 
-            dispatch(new SetupIndex($indexConfig, (bool) $this->option('delete')));
-
             Bus::batch([
-                [new PopulateIndex($indexConfig)],
-            ])
+                    [new SetupIndex($indexConfig, (bool) $this->option('delete'))],
+                    [new PopulateIndex($indexConfig)],
+                ])
+                ->onQueue(config('elastica-bridge.queue'))
                 ->then(function () use ($indexConfig): void {
-                    dispatch(new ActivateIndex($indexConfig));
+                    ActivateIndex::dispatch($indexConfig)
+                        ->onQueue(config('elastica-bridge.queue'));
                 })
                 ->name('ES index: '.$indexConfig->getName())
                 ->dispatch();