        (catch Exception e (do
                             (error e e)
                             (>!! error-ch e))))
-     (.set (:updated file-data) (System/currentTimeMillis)))
+     (.set ^AtomicReference (:updated file-data) (System/currentTimeMillis)))
   
   (defn write [{:keys [star error-ch] :as conn} file-key writer-f]
     "Writes the data in a thread safe manner to the file output stream based on the file-key

	               (do
                   (try
		                  (doseq [f roll-callbacks]
		                    (info "before roll") (f v) (info "after roll"))
                    
		                (catch Exception e (.printStackTrace e)))
                  (recur))))))
	        
	       (assoc conn :fix-delay-ch (fixdelay (:check-freq conn)

 
  (defn ^File create-file [base-dir codec file-key]
    "Create and return a File object with the name based on the file key codec and base dir"
       (File. (clojure.java.io/file base-dir)
              (str file-key 
                            (codec-extension codec)
                            "_" (System/nanoTime))))
      
