diff --git a/src/Iverberk/Larasearch/Jobs/ReindexJob.php b/src/Iverberk/Larasearch/Jobs/ReindexJob.php index 13a4177..623232a 100644 --- a/src/Iverberk/Larasearch/Jobs/ReindexJob.php +++ b/src/Iverberk/Larasearch/Jobs/ReindexJob.php @@ -56,7 +56,11 @@ public function fire(Job $job, $models) } } - $job->delete(); + if (method_exists($job,'getIronJob')) { + $job->getIron()->getIron()->deleteMessage($job->getQueue(), $job->getIronJob()->id, $job->getIronJob()->reservation_id); + } else { + $job->delete(); + } } } \ No newline at end of file