bus

v0.2.0

bus v0.2.0 Bus behaviour View Source

Link to this section Summary

Functions

child_spec(arg)

Returns a specification to start this module under a supervisor

publish(topic, message, qos \\ 1, dup \\ 0, retain \\ 0)
start_link(module, args)
stop()
subscribe(topics, qoses)
unsubscribe(list_of_topics)

Callbacks

on_connect()
on_disconnect()
on_message(binary)

Link to this section Functions

Link to this function child_spec(arg) View Source

Returns a specification to start this module under a supervisor.

See Supervisor.

Link to this function publish(topic, message, qos \\ 1, dup \\ 0, retain \\ 0) View Source 
publish(any(), any(), any(), any(), any()) :: :ok
Link to this function start_link(module, args) View Source 
start_link(any(), any()) :: :ignore | {:error, any()} | {:ok, pid()}
Link to this function subscribe(topics, qoses) View Source
Link to this function unsubscribe(list_of_topics) View Source

Link to this section Callbacks

Link to this callback on_connect() View Source (optional) 
on_connect() :: :ok
Link to this callback on_disconnect() View Source (optional) 
on_disconnect() :: :ok
Link to this callback on_message(binary) View Source (optional) 
on_message(binary()) :: :ok