Merge pull request #20 from esl/dont_stop

[change] don't stop consumer process if there is an error running a job
esl · Nov 30, 2018 · 015433c · 015433c
2 parents d5e03f7 + a688fa0
commit 015433c
Showing 1 changed file with 2 additions and 3 deletions.
diff --git 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