                                                                       (< (:t %) max-tx))
                                                                  entries)]
                                              (>!! read-ch
-                                                  (t/input (java.util.UUID/randomUUID)
+                                                  (t/input (random-uuid)
                                                            (update (into {} entry)
                                                                    :data
                                                                    (partial map unroll-log-datom)))))

  (retry-segment
    [_ event segment-id]
    (when-let [msg (get @pending-messages segment-id)]
      (>!! read-ch (assoc msg :id (java.util.UUID/randomUUID))))
    (swap! pending-messages dissoc segment-id))

  (pending?

            [onyx.peer.function :as function]
            [onyx.types :as t]
            [onyx.static.default-vals :refer [defaults]]
            [onyx.static.uuid :refer [random-uuid]]
            [onyx.extensions :as extensions]
            [taoensso.timbre :refer [info debug fatal]]))

