mqtt.clj

(ns aurora.models.lab
  (:require [clojure.java.jdbc :as sql]
            [twilio.core :as twilio]
            [clojurewerkz.machine-head.client :as mh]))

(defn send-mqtt [message & args]
  (let [id   (mh/generate-id)
        conn (mh/connect mqtt-url id)]
    (mh/subscribe conn ["gossamer"] (fn [^String topic _ ^bytes payload]
                                       (println (String. payload "UTF-8"))))
    (mh/publish conn "gossamer" message)
    {:status 200
     :headers {"Content-Type" "text/plain"}
     :body "Published Message!"}))