Skip to content

Commit 9d1e3e9

Browse files
committed
fix
1 parent 1b8fee1 commit 9d1e3e9

File tree

2 files changed

+3
-3
lines changed

2 files changed

+3
-3
lines changed

config/elastica-bridge.php

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -6,5 +6,5 @@
66
'port' => env('ELASTICSEARCH_PORT', '9200'),
77
],
88
'indices' => [],
9-
'queue' => env('ELASTICSEARCH_QUEUE', config('queue.default')),
9+
'connection' => env('ELASTICSEARCH_QUEUE_CONNECTION', config('queue.default')),
1010
];

src/Commands/IndexCommand.php

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -59,10 +59,10 @@ public function handle()
5959
[new SetupIndex($indexConfig, (bool) $this->option('delete'))],
6060
[new PopulateIndex($indexConfig)],
6161
])
62-
->onQueue(config('elastica-bridge.queue'))
62+
->onConnection(config('elastica-bridge.connection'))
6363
->then(function () use ($indexConfig): void {
6464
ActivateIndex::dispatch($indexConfig)
65-
->onQueue(config('elastica-bridge.queue'));
65+
->onConnection(config('elastica-bridge.connection'));
6666
})
6767
->name('ES index: '.$indexConfig->getName())
6868
->dispatch();

0 commit comments

Comments
 (0)