Packages

conduit

0.12.4
0.12.10 0.12.9 0.12.8 0.12.7 0.12.6 0.12.5 0.12.4 0.12.3 0.12.2 0.12.1 0.12.0 0.11.0 0.10.8 0.10.7 0.10.6 0.10.5 0.10.4 0.10.3 0.10.2 0.10.1 0.10.0 0.9.0 0.8.3 0.8.2 0.8.1 0.8.0 0.7.2 0.7.1 0.7.0 0.6.2 0.6.1 0.6.0 0.5.0 0.4.0 0.3.0 0.2.1 0.2.0 0.1.1 0.1.0

Message queue framework, with support for middleware and multiple adapters.

HexDocs

Current section

39 Versions

Jump to
Readme
39 Versions
3 Dependencies
5 Dependants
Files
Activity
Hide whitespace

Compare versions

3 files changed
+10 additions
-10 deletions
  @@ -60,4 +60,4 @@
60 60 {<<"optional">>,false},
61 61 {<<"repository">>,<<"hexpm">>},
62 62 {<<"requirement">>,<<"~> 3.0">>}]]}.
63 - {<<"version">>,<<"0.12.3">>}.
63 + {<<"version">>,<<"0.12.4">>}.
  @@ -46,7 +46,7 @@ defmodule Conduit.Plug.Retry do
46 46 end
47 47 rescue
48 48 error ->
49 - retry(message, next, retries, error, opts)
49 + retry(message, next, retries, error, System.stacktrace(), opts)
50 50 end
51 51
52 52 defp retry(message, _, retries, :nack, %{attempts: attempts})
  @@ -54,17 +54,17 @@ defmodule Conduit.Plug.Retry do
54 54 nack(message)
55 55 end
56 56
57 - defp retry(_, _, retries, error, %{attempts: attempts})
57 + defp retry(_, _, retries, error, stacktrace, %{attempts: attempts})
58 58 when retries >= attempts - 1 do
59 - reraise error, System.stacktrace()
59 + reraise error, stacktrace
60 60 end
61 61
62 - defp retry(message, next, retries, error, opts) do
62 + defp retry(message, next, retries, error, stacktrace, opts) do
63 63 delay = opts.delay * :math.pow(opts.backoff_factor, retries)
64 64 jitter = :rand.uniform() * delay * opts.jitter
65 65 wait_time = round(delay + jitter)
66 66
67 - log_error(error, wait_time)
67 + log_error(error, stacktrace, wait_time)
68 68
69 69 Process.sleep(wait_time)
70 70
  @@ -74,12 +74,12 @@ defmodule Conduit.Plug.Retry do
74 74 |> attempt(next, retries + 1, opts)
75 75 end
76 76
77 - defp log_error(:nack, wait_time) do
77 + defp log_error(:nack, _, wait_time) do
78 78 Logger.warn("Message will be retried in #{wait_time}ms because it was nacked")
79 79 end
80 80
81 - defp log_error(error, wait_time) do
82 - formatted_error = Exception.format(:error, error)
81 + defp log_error(error, stacktrace, wait_time) do
82 + formatted_error = Exception.format(:error, error, stacktrace)
83 83
84 84 Logger.warn([
85 85 "Message will be retried in #{wait_time}ms because an exception was raised\n",
  @@ -4,7 +4,7 @@ defmodule Conduit.Mixfile do
4 4 def project do
5 5 [
6 6 app: :conduit,
7 - version: "0.12.3",
7 + version: "0.12.4",
8 8 elixir: "~> 1.3",
9 9 build_embedded: Mix.env() == :prod,
10 10 start_permanent: Mix.env() == :prod,