clj-aws-iot-client.core — clj-aws-iot-client 0.1.0-alpha1

defenumlookups clj macro

(defenumlookups enum from-name to-name)

A helper macro that builds lookup functions for enums. all values of enum are turned into a map of keywords to enum values. This macro provides two functions: one named from-name->to-name and one named to-name->from-name, for example: (defenumlookups AWSIotQos kw qos) creates (defn- kw->qos [kw]) which takes a keyword and returns an enum value, and (defn- qos->kw [e]) which takes an enum value and returns a keyword.

get-base-retry-delay clj

(get-base-retry-delay client)

get-client-endpoint clj

(get-client-endpoint client)

get-client-id clj

(get-client-id client)

get-connection clj

(get-connection client)

get-connection-status clj

(get-connection-status client)

get-connection-timeout clj

(get-connection-timeout client)

get-connection-type clj

(get-connection-type client)

get-devices clj

(get-devices client)

get-execution-service clj

(get-execution-service client)

get-keep-alive-interval clj

(get-keep-alive-interval client)

get-max-connection-retries clj

(get-max-connection-retries client)

get-max-offline-queue-size clj

(get-max-offline-queue-size client)

get-max-retry-delay clj

(get-max-retry-delay client)

get-num-of-client-threads clj

(get-num-of-client-threads client)

get-server-ack-timeout clj

(get-server-ack-timeout client)

get-subscriptions clj

(get-subscriptions client)

get-will-message clj

(get-will-message client)

mqtt-client clj

(mqtt-client authentication-method
             {:keys [client-endpoint client-id keystore aws-access-key-id
                     aws-secret-access-key session-token key-password]
              :as config})

Returns an MQTT client, which handles connection to an MQTT endpoint authentication method can be either :tls or :wss :tls requires :client-endpoint, :client-id, :keystore, and :key-password :wss requires :client-id, :aws-access-key-id, and optionally :session-token

publish-async clj

(publish-async client message)

Given a client and a message, which is constructed by a publisher, asynchronously publish that message

publish-blocking clj

(publish-blocking client topic payload)

(publish-blocking client topic payload {:keys [qos timeout] :as opts})

Given an MQTT client client, a string topic, and, optionally, a keyword qos and a number timeout. Always returns the client

publisher clj

(publisher on-success on-failure on-timeout)

Takes three zero-arity functions, on-success, on-failure, and on-timeout, and returns a function that takes a string topic, keyword qos, and a string or byte array payload, this function can in turn construct a message which can be passed to publish-async

schedule-routine-task clj

(schedule-routine-task client f initial-delay period)

schedule-timeout-task clj

(schedule-timeout-task client f timeout)

set-will-message clj

(set-will-message client message)

subscribe clj

(subscribe client subscription)

Applies a subscription to a client, firing the subscription's on-message whenever a message is received to topic

subscription clj

(subscription topic qos on-message)

Given a topic string, qos keyword, and a 1-arity function that takes a message, returns a subscription, which can be added to a client