(close socket)(connack-reason socket reason)(connect socket opts)(connected? socket)Check if a socket is currently connected.
Check if a socket is currently connected.
(disconnect socket)(disconnected? socket & {:keys [timeout] :or {timeout 1000}})Check if a socket receives no more messages and is disconnected.
Check if a socket receives no more messages and is disconnected.
(expect-message socket f & {:keys [timeout]})(get-next-message-id socket)(open? socket)Check if a socket is currently connected.
Check if a socket is currently connected.
(ping socket)(publish socket
topic
payload
&
{:keys [qos message-id wait]
:or {qos 1 message-id (get-next-message-id socket) wait true}})(raw-send-message socket msg)(recv-message socket)(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.
Send a packet from the client. We use the 'done' channel as a mutex so we can block until the send is done.
(socket)(socket addr)Creates and connects a raw mqtt socket to the address. Returns two chans an input one and an output one.
Creates and connects a raw mqtt socket to the address. Returns two chans an input one and an output one.
(subscribe socket topic-qos-pairs)(unsubscribed-messages socket)(with-client [client opts] & body)cljdoc builds & hosts documentation for Clojure/Script libraries
| Ctrl+k | Jump to recent docs |
| ← | Move to previous article |
| → | Move to next article |
| Ctrl+/ | Jump to the search field |