Hugh JF Chen hughjfchen
hughjfchen
/ gist:ff36cc656fe7c75ae2f3509def022a0e
Created
December 12, 2017 07:13
— forked from malcolmsparks/gist:6044878
MQTT example for Clojure core.async
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| (ns mqtt-insertion.core | |
| (:require [clojure.core.async :refer :all]) | |
| (:import (org.eclipse.paho.client.mqttv3 | |
| MqttCallback | |
| MqttAsyncClient | |
| MqttConnectOptions | |
| MqttDeliveryToken | |
| MqttException | |
| MqttMessage | |
| MqttTopic |