Popularity
4.0
Declining
Activity
0.0
Stable
23
3
9

Description

Elixir wrapper for the emqttc library.

emqttc must currently be installed manually as it is not available on hex (yet).

Monthly Downloads: 242
Programming language: Elixir
License: MIT License

Exmqttc alternatives and similar packages

Based on the "Third Party APIs" category.
Alternatively, view Exmqttc alternatives based on common mentions on social networks and blogs.

Do you think we are missing an alternative of Exmqttc or a related project?

Add another 'Third Party APIs' Package

README

Exmqttc Deps Status Build Status Inline docs

Elixir wrapper for the emqttc library.

emqttc must currently be installed manually as it is not available on hex (yet).

Installation

The package can be installed by adding exmqttc and emqttc to your list of dependencies in mix.exs:

def deps do
  [{:exmqttc, "~> 0.5"}, {:emqttc, github: "emqtt/emqttc"}]
end

Usage

Create a callback module:

defmodule MyClient do
  require Logger
  use Exmqttc.Callback

  def init(_params) do
    {:ok, []}
  end

  def handle_connect(state) do
    Logger.debug "Connected"
    {:ok, state}
  end

  def handle_disconnect(state) do
    Logger.debug "Disconnected"
    {:ok, state}
  end

  def handle_publish(topic, payload, state) do
    Logger.debug "Message received on topic #{topic} with payload #{payload}"
    {:ok, state}
  end
end

You can keep your own state and return it just like with :gen_server.

Start the MQTT connection process by calling start_link/3:

{:ok, pid} = Exmqttc.start_link(MyClient, [], [host: '127.0.0.1'], params)

The third argument is a list of emqtt connection options, supporting the following options

  • host: Connection host, charlist, default: 'localhost'
  • port: Connection port, integer, default 1883
  • client_id: Binary ID for client, automatically set to UUID if not specified
  • clean_sess: MQTT cleanSession flag. true disables persistent sessions on the server
  • keepalive: Keepalive timer, integer
  • username: Login username, binary
  • password: Login password, binary
  • will: Last will, keywordlist, sample: [qos: 1, retain: false, topic: "WillTopic", payload: "I died"]
  • connack_timeout: Timeout for connack package, integer, default 60
  • puback_timeout: Timeout for puback package, integer, default 8
  • suback_timeout: Timeout for suback package, integer, default 4
  • ssl: List of ssl options
  • auto_resub: Automatically resubscribe to topics, boolean, default: false
  • reconnect: Automatically reconnect on lost connection, integer (), default false

Params are passed to the init function of your callback module.

You can publish messages to the given PID:

Exmqttc.publish(pid, "test", "foo")

publish/4 also supports passing in QOS and retain options:

Exmqttc.publish(pid, "test", "foo", qos: 2, retain: true)

Further docs can be found at https://hexdocs.pm/exmqttc.