 
 (def rethinkdb-pool
   (do (when (bound? #'rethinkdb-pool) (shutdown-pool! rethinkdb-pool))
-      (fixed-pool init-conn close-conn {:size config/db-pool-size
-                                              :regenerate-interval 15})))
+      (fixed-pool init-conn rethinkdb.core/close {:size config/db-pool-size
+                                                  :regenerate-interval 15})))
 
 
 (comment

;; --- Define stateful pool & functions to rebuild

(defn shutdown-pool!
  [pool]
  (doseq [thing (to-array (:queue pool))]
    ((:close pool) thing))


;; Opening & closing of connections

(defn init-conn
  "Create a new RethinkDB connection based on global configuration"
  []
  (apply r/connect config/db-options))

;; Taken from the wonderful aphyr's Riemann
;; https://github.com/riemann/riemann/blob/master/src/riemann/pool.clj
