     :onyx/consumption :concurrent
     :onyx/batch-size batch-size}
 
-   {:onyx/name :process-blue
+   {:onyx/name :process-green
     :onyx/fn :onyx.peer.flow-test/process-green
     :onyx/type :function
     :onyx/consumption :concurrent

  {: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 washington-resident? [event {:keys [location]}]
  (= location "Washington"))

(defn black? [{:keys [color]}]
  (= color "black"))

(defn white? [{:keys [color]}]
  (= color "white"))

(defn red? [event {:keys [color]}]
  (= color "red"))

