From a688fa07451778b80c6a85002a262c763e624668 Mon Sep 17 00:00:00 2001 From: sescobb27 Date: Fri, 30 Nov 2018 09:15:47 -0500 Subject: [PATCH] [change] don't stop consumer process if there is an error running a job --- apps/repo_jobs/lib/repo_jobs/consumer.ex | 5 ++--- 1 file changed, 2 insertions(+), 3 deletions(-) diff --git a/apps/repo_jobs/lib/repo_jobs/consumer.ex b/apps/repo_jobs/lib/repo_jobs/consumer.ex index 4667fa7..6324ce4 100644 --- a/apps/repo_jobs/lib/repo_jobs/consumer.ex +++ b/apps/repo_jobs/lib/repo_jobs/consumer.ex @@ -142,13 +142,12 @@ defmodule RepoJobs.Consumer do :ok = client.reject(channel, delivery_tag, requeue: true) if caller, do: send(caller, {:reject, error}) end - - {:noreply, state} rescue exception -> :ok = client.reject(channel, delivery_tag, requeue: true) if caller, do: send(caller, {:reject, exception}) - {:stop, exception, state} + after + {:noreply, state} end end