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

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

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

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

(defn bk-cfg-servers
  [test]
