            (.submit ^Callable (until-interrupted
                                (executors/safe-task
                                 #(listen-for-gis-changes refresh-async!)))))
-  :stop (.shutdownNow ^ScheduledExecutorService notified-refresh))
+  :stop (.shutdownNow ^ExecutorService notified-refresh))

  (:import (com.google.common.util.concurrent ThreadFactoryBuilder)
           (java.time Duration)
           (java.util UUID)
           (java.util.concurrent Executors ScheduledExecutorService TimeUnit)
           (org.postgresql PGConnection)))

(defn- process-changes! [conn state had-changes?]

  :start (doto (Executors/newScheduledThreadPool 1 scheduled-refresh-thread-factory)
           (.scheduleWithFixedDelay (executors/safe-task refresh-async!)
                                    0 1 TimeUnit/MINUTES))
  :stop (.shutdown ^ExecutorService scheduled-refresh))


(defn listen-for-gis-changes [notify]
