     (when (compare-and-set! state :started :stopped)
       (do
         (ning-client/close-client client)
-        (record-end recorder)
+        (rec/record-end recorder)
         (doseq [worker @workers]
           (swap! (:state worker) (fn [s] :stopped)))
         (broadcast-state this))))

    (if (not (compare-and-set! state :initialized :started))
      (io! (log/warn (str "Could not start from: @state")))
      (do
        (record-start recorder)
        (doseq [worker @workers]
          (if-let [res-ch (work worker)]
            (handle-result this res-ch)))
        (compare-and-set! broadcast-task nil
                          (broadcast-at-interval this 200)))))

(defn create-benchmark
 "Create a new Benchmark record. This encapsulates the full benchmark state"
 [client url worker-count max-runs worker-fn]
 (let [recorder (rec/create-recorder)
       benchmark (Benchmark. (atom :initialized)
                             client
                             url
