             [ring.middleware.stacktrace :refer (wrap-stacktrace)]
             [ring.util.mime-type]
             [ring.util.response :refer (response)])
-  (:import java.security.Principal
+  (:import clojure.core.async.impl.channels.ManyToManyChannel
+           java.io.IOException
+           java.security.Principal
            javax.security.auth.Subject
+           javax.servlet.ServletInputStream
            org.apache.curator.framework.CuratorFrameworkFactory
            org.apache.curator.framework.state.ConnectionStateListener
            org.apache.curator.retry.BoundedExponentialBackoffRetry

        (h req)
        (auth-fn req)))))

(def scheduler-server
  (graph/eager-compile
    {:route full-routes

                                                               wrap-params
                                                               (cors/cors-middleware cors-origins)
                                                               (health-check-middleware mesos-leadership-atom leader-reports-unhealthy)
                                                               instrument
                                                               consume-request-stream))
                                           :join? false
                                           :configurator configure-jet-logging
                                           :max-threads 200
