Packages

freddy

0.17.2
0.17.2 0.17.1 0.17.0 0.17.0-rc.5 0.17.0-rc.4 0.17.0-rc.3 0.17.0-rc.2 0.17.0-rc 0.16.0 0.15.2 0.15.1 0.15.0 0.14.0 0.13.1 0.13.0 0.12.1 0.12.0 0.11.0 0.10.2 0.10.1 0.10.0 0.9.2 0.9.1 retired 0.9.0

JSON RPC Client/Server, JSON Publisher-Subscriber over AMQP

HexDocs

Current section

Files

Jump to
Readme
24 Versions
5 Dependencies
Dependants
Files
Activity
freddy lib freddy utils safe_amqp.ex
Raw

lib/freddy/utils/safe_amqp.ex 

defmodule Freddy.Utils.SafeAMQP do

  @moduledoc false

  # A macro for safer execution of some operations



  @recoverable_error_codes [311, 320]



  defmacro safe_amqp([on_error: on_error], do: expr) do

    quote do

      try do

        unquote(expr)

      rescue

        MatchError ->

          # amqp 0.x throws MatchError when server responds with non-OK

          unquote(on_error)

      catch

        # recoverable

        :exit, {{:shutdown, {:server_initiated_close, code, _}}, _}

        when code in unquote(@recoverable_error_codes) ->

          {:error, :closed}



        # unrecoverable

        :exit, {{:shutdown, {:server_initiated_close, _, _}}, _} ->

          unquote(on_error)



        :exit, _ ->

          {:error, :closed}

      end

    end

  end

end