Packages

conduit

0.12.0
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

Files

Jump to
Readme
39 Versions
3 Dependencies
5 Dependants
Files
Activity
conduit lib conduit plug ack_exception.ex
Raw

lib/conduit/plug/ack_exception.ex 

defmodule Conduit.Plug.AckException do

  use Conduit.Plug.Builder

  require Logger



  @moduledoc """

  Rescues any exception and acks the message.



  Options are ignored.



  ## Examples



      plug Conduit.Plug.AckException



  """



  @doc """

  Rescues any exception and acks the message.

  """

  def call(message, next, _opts) do

    next.(message)

  rescue

    error ->

      formatted_error = Exception.format(:error, error)



      Logger.warn([

        "Ignoring raised exception because exceptions are set to be acked\n",

        formatted_error

      ])



      ack(message)

  end

end