mqtt.test-client — kotyo/clj-mqtt 0.4.10

*default-host* clj

*default-port* clj

close clj

(close socket)

closed? clj

connack-reason clj

(connack-reason socket reason)

connect clj

(connect socket opts)

connected? clj

(connected? socket)

Check if a socket is currently connected.

disconnect clj

(disconnect socket)

disconnected? clj

(disconnected? socket & {:keys [timeout] :or {timeout 1000}})

Check if a socket receives no more messages and is disconnected.

expect-message clj

(expect-message socket f & {:keys [timeout]})

get-next-message-id clj

(get-next-message-id socket)

open? clj

(open? socket)

Check if a socket is currently connected.

ping clj

(ping socket)

publish clj

(publish socket
         topic
         payload
         &
         {:keys [qos message-id wait]
          :or {qos 1 message-id (get-next-message-id socket) wait true}})

raw-send-message clj

(raw-send-message socket msg)

recv-message clj

(recv-message socket)

send-message clj

(send-message socket msg)

Send a packet from the client. We use the 'done' channel as a mutex so we can block until the send is done.

socket clj

(socket)

(socket addr)

Creates and connects a raw mqtt socket to the address. Returns two chans an input one and an output one.

subscribe clj

(subscribe socket topic-qos-pairs)

unsubscribed-messages clj

(unsubscribed-messages socket)

with-client clj macro

(with-client [client opts] & body)