From 6b6b4f73eecd4c688fa540aea9feaf466ad8cced Mon Sep 17 00:00:00 2001 From: Mahmood Damery Date: Wed, 27 Jul 2016 18:35:40 +0300 Subject: [PATCH] delete method --- src/Iverberk/Larasearch/Jobs/ReindexJob.php | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) 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