Packages

mammoth

0.4.5
0.5.3 0.5.2 0.5.1 0.5.0 0.4.10 0.4.9 0.4.8 0.4.7 0.4.6 0.4.5 0.4.4 0.4.3 0.4.2 0.4.1 0.4.0 0.3.3 0.3.2 0.3.1 0.3.0 0.2.0 0.1.0 0.0.1 0.0.0

A STOMP client to listen to, for example, AMQ. A fork of ericteubert's Elephant package.

HexDocs

Current section

Files

Jump to
Readme
23 Versions
0 Dependencies
Dependants
Files
Activity
mammoth lib mammoth socket.ex
Raw

lib/mammoth/socket.ex 

defmodule Mammoth.Socket do

  alias Mammoth.Message



  require Logger



  def connect(host, port) do

    {:ok, conn} = :gen_tcp.connect(host, port, [{:active, false}])

    :inet.setopts(conn, [{:recbuf, 1024}])

    {:ok, conn}

  end



  def send(conn, message = %Mammoth.Message{}) do

    __MODULE__.send(conn, Message.format(message))

  end



  def send(conn, message) when is_binary(message) do

    Logger.debug(inspect(message))

    :gen_tcp.send(conn, message)

  end



  def receive(conn, length \\ 0) do

    response = :gen_tcp.recv(conn, length)



    case response do

      {:ok, response} -> Logger.debug(inspect(response, binaries: :as_strings))

      _ -> Logger.debug("Got response that was not :ok")

    end



    response

  end

end