Riemann.io exceptions to events

riemann.config.clj

;; watchdog-cfg is just a hash with host, port, etc.
(streams
  ;; irrelevant code ommited :)
 (where (service #"riemann server")
    (let [send-watchdog (forward (riemann.client/tcp-client watchdog-cfg))]
      (fn watchdog-sending [event]
       (try (send-watchdog event)
         (catch Exception exc
            (tell-ops (utils/exception->event exc))))))))

utils.clj

(ns bla-bla.utils
  (require [clj-time.core :as ct])
  (require [clj-time.coerce :as tc]))

(defn exception->event
  [exc]
  {:host "riemann.local"
   :service "riemann"
   :state "critical"
   :metric 1
   :tags []
   :ttl 60
   :description (str exc)
   :time (tc/to-long (ct/now))})