dvlopt.mqtt.v3 — dvlopt/mqtt 0.0.1

Functions for opening and handling a connection using the MQTT 3.x protocol. All functions are specified using clojure.spec.

Specs related to options and callbacks.

ack clj

(ack client message)

Manually acknowledges a received message.

Should not be used unless the client has been connected with the ::dvlopt.mqtt/manual-acks? option set to true.

buffer-count clj

(buffer-count client)

Counts how many messages are currently buffered for reliability.

buffer-get clj

(buffer-get client index)

Gets a buffered message.

client-id clj

(client-id client)

What is the client-id of the given client ?

close clj

(close client)

(close client opts)

Closes a client and releases all associated resources.

connected? clj

(connected? client)

Is the given client currently connected ?

current-uri clj

(current-uri client)

To which uri is the given client currently connected ?

open clj

(open)

(open opts)

Builds a client and opens a connection.

Returns a map containing the ::client as well as values for options that have default values.

publish clj

(publish client topic opts)

Publishes to a topic.

subscribe clj

(subscribe client subscriptions)

(subscribe client subscriptions opts)

Subscribes the given client to topics.

unsubscribe clj

(unsubscribe client topics)

(unsubscribe client topics opts)

Unsubscribes the given client from topics.