Current section
Files
Jump to
Current section
Files
lib/transport.ex
defmodule Pixie.Transport do
import Pixie.Utils.String
def get transport_name, client_id do
id = "transport:#{client_id}"
transport_name = transport_name
|> String.split("-")
|> Enum.join("_")
|> camelize(true)
module = Module.concat __MODULE__, transport_name
Pixie.Supervisor.replace_worker module, id, []
end
def advice transport, advice do
GenServer.call transport, {:advice, advice}
end
def await transport, messages do
GenServer.call transport, {:await, messages}, Pixie.timeout * 2
end
def enqueue transport, messages do
GenServer.cast transport, {:enqueue, messages}
end
end