             [com.stuartsierra.component :as component]
             [clj-http.client :refer [post]]
             [taoensso.timbre :refer [info]]
-            [onyx.system :as system]))
+            [onyx.coordinator.impl :as impl]
+            [onyx.system :as system]
+            [onyx.extensions :as extensions]))
 
 (defprotocol ISubmit
   "Protocol for sending a job to the coordinator for execution."

      (>!! (:planning-ch-head (:coordinator onyx-coord)) [job ch])
      (<!! ch)))

  IRegister
  (register-peer [this peer-node]
    (>!! (:born-peer-ch-head (:coordinator onyx-coord)) peer-node))

  (shutdown [this]))

(defmulti connect
  "Establish a communication channel with the coordinator."
  (fn [uri opts] (keyword (first (split (second (split uri #":")) #"//")))))

(defmethod connect :memory
