Packages

reactive_commons

0.8.5
1.5.0 1.4.1 1.4.0 1.3.0 1.2.1 1.2.0 1.1.0 1.0.2 1.0.0 0.8.5 0.8.4 0.8.3 0.8.2 0.8.1 0.8.0 0.7.1 0.7.0 0.6.2 0.6.1

Domain driven async abstractions like Domain Event Bus, Event subscriptions/emit, Async Command handling and Async Req/Reply.

HexDocs

Current section

Files

Jump to
Readme
19 Versions
4 Dependencies
Dependants
Files
Activity
reactive_commons lib reactive_commons utils header_extractor.ex
Raw

lib/reactive_commons/utils/header_extractor.ex 

defmodule HeaderExtractor do



  def get_x_death_count(headers) do

    case get_header_value(headers, MessageHeaders.h_X_DEATH()) do

      nil -> 0

      [ {_, sub_h} | _] -> get_header_value(sub_h, MessageHeaders.h_X_DEATH_COUNT(), 0)

    end

  end



  def get_header_value(headers, name, default \\ nil) do

    case headers |> Enum.find(match_header(name)) do

      nil -> default

      e -> elem(e, 2)

    end

  end



  defp match_header(name) do

    fn

      {^name, _, _} -> true

      _ -> false

    end

  end



end