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

                                                                      (< (:t %) max-tx))
                                                                 entries)]
                                             (>!! read-ch
                                                  (t/input (java.util.UUID/randomUUID)
                                                           (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 (random-uuid))))
    (swap! pending-messages dissoc segment-id))

  (pending?
