    :onyx.coordinator/port onyx-port-2
    :onyx.coordinator/revoke-delay 5000})
 
-(def onyx-server-2 (future (d/start-distributed-coordinator coord-opts-2)))
+(def onyx-server-2 (future (onyx.api/start-distributed-coordinator coord-opts-2)))
 
 (def conn (onyx.api/connect :distributed coord-opts))
 

   :zookeeper/address "localhost:2181"
   :onyx/id id})

(def onyx-server (d/start-distributed-coordinator coord-opts))

(def onyx-port-2 (+ 10000 (rand-int 10000)))


  ((:shutdown-fn v-peer)))

(onyx.api/shutdown conn)
(onyx.api/stop-distributed-coordinator onyx-server)

(let [expected (set (map (fn [x] {:n (inc x)}) (range n-messages)))]
  (fact (set (butlast results)) => expected)
