pixie v0.3.9 Pixie.Transport.Default behaviour

Summary

Callbacks

dequeue_messages({})

Specs

dequeue_messages({waiting :: pid | nil, queued_messages :: [map]}) :: {nil, list}
enqueue_messages(messages, {})

Specs

enqueue_messages(messages :: [map], {from :: pid | nil, queued_messages :: [map]}) :: {nil | pid, list}
start_link()

Specs

start_link :: {atom, pid}