Packages

riemann

0.0.16
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

        Riemann.Worker.call(:pool, {:send_msg, [msg]}, timeout)

      end



      def send_async(msg) do

        Riemann.Worker.cast(:pool, {:send_msg, [msg]})

      end



    end

  end

end