             (send-command! "deactivate node" 1 node)))))
 
      (sleep))))
+
+(defn check-for-updates
+  "This will fetch the latest version number of PuppetDB and log if the system
+  is out of date."
+  []
+  (let [upgrade        (upgrade-info)
+        latest-version (:version upgrade)
+        out-of-date?   (:newer upgrade)]
+    (when out-of-date?
+      (log/info (format "Newer version %s is available!" latest-version)))))
 
 (defn configure-commandproc-threads
   "Update the supplied config map with the number of

        [clojure.tools.nrepl.transport :only (tty tty-greeting)]
        [clojure.core.incubator :only (-?>)]
        [com.puppetlabs.jdbc :only (with-transacted-connection)]
        [com.puppetlabs.utils :only (cli! configure-logging! inis-to-map with-error-delivery version)]
        [com.puppetlabs.puppetdb.scf.migrate :only [migrate!]]))

(def cli-description "Main PuppetDB daemon")

                          (vec (for [n (range nthreads)]
                                 (future (with-error-delivery error
                                           (load-from-mq mq-addr mq-endpoint discard-dir db))))))
          updater       (future (check-for-updates))
          web-app       (let [authorized? (if-let [wl (jetty :certificate-whitelist)]
                                            (pl-utils/cn-whitelist->authorizer wl)
                                            (constantly true))
