 
 (def out-chan-2 (chan (sliding-buffer (inc n-messages))))
 
-(defmethod l-ext/inject-lifecycle-resources :in-1
-  [_ _] {:core.async/chan in-chan-1})
-
-(defmethod l-ext/inject-lifecycle-resources :out-1
-  [_ _] {:core.async/chan out-chan-1})
-
-(defmethod l-ext/inject-lifecycle-resources :in-2
-  [_ _] {:core.async/chan in-chan-2})
-
-(defmethod l-ext/inject-lifecycle-resources :out-2
-  [_ _] {:core.async/chan out-chan-2})
-
 (try
   ;;; Don't write any segments to j1 so that the job will stay alive until we kill it.
   (doseq [n (range n-messages)]

            [onyx.peer.task-lifecycle-extensions :as l-ext]
            [onyx.plugin.core-async :refer [take-segments!]]
            [onyx.test-helper :refer [load-config]]
            [onyx.api]))

(def id (java.util.UUID/randomUUID))

      :onyx/type :function
      :onyx/batch-size batch-size}

     {:onyx/name :out-1
      :onyx/ident :core.async/write-to-chan
      :onyx/type :output
      :onyx/medium :core.async
