 
 (defn ack-path [prefix]
   (str root-path "/" prefix "/ack"))
+
+(defn exhaust-path [prefix]
+  (str root-path "/" prefix "/exhaust"))
+
+(defn seal-path [prefix]
+  (str root-path "/" prefix "/seal"))
 
 (defn completion-path [prefix]
   (str root-path "/" prefix "/completion"))

      (zk/create conn (pulse-path prefix) :persistent? true)
      (zk/create conn (payload-path prefix)  :persistent? true)
      (zk/create conn (ack-path prefix) :persistent? true)
      (zk/create conn (completion-path prefix) :persistent? true)
      (zk/create conn (status-path prefix) :persistent? true)
      (zk/create conn (catalog-path prefix) :persistent? true)

    (zk/create (:conn sync) place :persistent? true)
    place))

(defmethod extensions/create [ZooKeeper :exhaust]
  [sync _]
  (let [prefix (:onyx-id sync)
        place (str (exhaust-path prefix) "/" (UUID/randomUUID))]
    (zk/create (:conn sync) place :persistent? true)
    place))

(defmethod extensions/create [ZooKeeper :seal]
  [sync _]
  (let [prefix (:onyx-id sync)
        place (str (seal-path prefix) "/" (UUID/randomUUID))]
    (zk/create (:conn sync) place :persistent? true)
    place))

(defmethod extensions/create [ZooKeeper :completion]
  [sync _]
  (let [prefix (:onyx-id sync)
