                     (try
                       (do 
                         (info "Adding entry" (:value op))
-                        (.addEntry ledger-handle (nippy/compress (:value op)))
+                        (.addEntry ledger-handle (nippy/window-log-compress (:value op)))
                         (info "Done adding entry" (:value op))
                         (assoc op :type :ok :ledger-id (.getId ledger-handle)))
                       (catch Throwable t

                        (loop [results [] 
                               entries (.readEntries ledger-handle 0 last-confirmed)
                               element ^LedgerEntry (.nextElement entries)] 
                          (let [new-results (conj results (nippy/decompress (.getEntry element)))] 
                            (if (.hasMoreElements entries)
                              (recur new-results entries (.nextElement entries))
                              new-results)))

(def || (c/lit "||"))

(def env-config 
  (-> "resources/prod-env-config.edn" slurp read-string))

(defn bk-cfg-servers
  [test]
