    :zookeeper/address "localhost:2181"
    :onyx/id id})
 
-(def onyx-server (d/start-distributed-coordinator coord-opts))
+(def onyx-server (onyx.api/start-distributed-coordinator coord-opts))
 
 (def onyx-port-2 (+ 10000 (rand-int 10000)))
 

(ns onyx.coordinator.coordinator-ha-test
  (:require [midje.sweet :refer :all]
            [onyx.queue.hornetq-utils :as hq-util]
            [onyx.coordinator.distributed :as d]
            [onyx.api]))

(def config (read-string (slurp (clojure.java.io/resource "test-config.edn"))))

(onyx.api/submit-job conn {:catalog catalog :workflow workflow})

(Thread/sleep 10000)
(onyx.api/stop-distributed-coordinator onyx-server)

(def results (hq-util/consume-queue! hq-config out-queue echo))

