     :hornetq/queue-name blue-out-queue
     :hornetq/host (:host (:non-clustered (:hornetq config)))
     :hornetq/port (:port (:non-clustered (:hornetq config)))
-    :onyx/batch-size batch-size}]
-
-  {:onyx/name :green-out
-   :onyx/ident :hornetq/write-segments
-   :onyx/type :output
-   :onyx/medium :hornetq
-   :onyx/consumption :concurrent
-   :hornetq/queue-name green-out-queue
-   :hornetq/host (:host (:non-clustered (:hornetq config)))
-   :hornetq/port (:port (:non-clustered (:hornetq config)))
-   :onyx/batch-size batch-size})
+    :onyx/batch-size batch-size}
+
+   {:onyx/name :green-out
+    :onyx/ident :hornetq/write-segments
+    :onyx/type :output
+    :onyx/medium :hornetq
+    :onyx/consumption :concurrent
+    :hornetq/queue-name green-out-queue
+    :hornetq/host (:host (:non-clustered (:hornetq config)))
+    :hornetq/port (:port (:non-clustered (:hornetq config)))
+    :onyx/batch-size batch-size}])
 
 (def workflow
   [[:people-in :process-children]

  {:color "yellow"}]
 echo)

(defn my-inc [{:keys [n] :as segment}]
  (assoc segment :n (inc n) :extra-key :blah))

(def catalog
  [{:onyx/name :people-in
    :onyx/ident :hornetq/read-segments

(defn process-blue [segment]
  (assoc segment :extra-key "Some extra context for the predicates"))

(defn process-green [segment]
  (assoc segment :extra-key "Some extra context for the predicates"))

(def v-peers (onyx.api/start-peers! 1 peer-config))
