Give 'handler a type and use that to create a consumer for the appropriate exchange in rabbitmq

elsewhere

(defrecord InQueue [rabbitmq handler queue-names routing-keys]
  component/Lifecycle
  (start [this]
    (println ";; Starting OutQueue")
    (let [{:keys [connection]} rabbitmq
          [type* handler-fn] handler
          queue-name (->> queue-names
                          (filter #(= (first %) type*))
                          (first))
          binding-queue (str (:ns (meta handler-fn)))]
      (que connection queue-name routing-keys binding-queue)))
  (stop [this]
    nil))

some module

(def type*
  :command)

(defhandler handler
  [type* process-command])