Packages

white_rabbit

0.2.0
0.2.1 0.2.0

Library to handle all consuming, producing, and exchanging of RabbitMQ messages via AMQP 0-9-1 protocol. Also enables RPC across independent OTP apps over RabbitMQ queues.

HexDocs

Current section

Files

Jump to
Readme
2 Versions
3 Dependencies
Dependants
Files
Activity
white_rabbit lib white_rabbit RPC message.ex
Raw

lib/white_rabbit/RPC/message.ex 

defmodule WhiteRabbit.RPC.Message do

  @moduledoc """

  RPC message modlue that defines a struct and convert functions.



  """



  @enforce_keys [:module, :function, :args, :caller_id]

  @derive [Jason.Encoder]

  defstruct module: nil, function: nil, args: nil, caller_id: nil



  def convert!(data) when is_map(data) do

    %__MODULE__{

      module: data["module"],

      function: data["function"],

      args: data["args"],

      caller_id: data["caller_id"]

    }

  end



  def convert!(data) do

    data

  end

end