Packages

riemann

0.1.1
0.1.6 0.1.5 0.1.3 0.1.2 0.1.1 0.0.16 0.0.15 0.0.14 0.0.13 0.0.12 0.0.11 0.0.10 0.0.9 0.0.8 0.0.7 0.0.6 0.0.5 0.0.4 0.0.3 0.0.2 0.0.1

A client for the Riemann event stream processor

HexDocs

Current section

Files

Jump to
Readme
21 Versions
2 Dependencies
Dependants
Files
Activity
riemann lib riemann helpers msg.ex
Raw

lib/riemann/helpers/msg.ex 

defmodule Riemann.Helpers.Msg do

  defmacro __using__(_opts) do

    quote do

      def send(msg, timeout \\ 5000) do

        {:send_msg, [msg]}

        |> Honeydew.async(:riemann_pool, reply: true)

        |> Honeydew.yield(timeout)

        |> case do

             {:ok, ok} -> ok

             nil -> :timeout

           end

      end



      def send_async(msg) do

        Honeydew.async({:send_msg, [msg]}, :riemann_pool)

      end

    end

  end

end