             (log/info (str "Result Received Topic: [" topic "]"))
             (log/info (str "Result Received payload: [" payload "]"))
             (match [topic payload]
+                   ['app/select-activity _]
+                   (do
+                     (log/info (str "Select activity " payload))
+                     (select-activity payload))
                    [:set-result p]
                    (log/info "Mark X")
                    :else (async/>!!

            (log/error e "Exception in Broker message go loop")
            (async/>! out-ch (str "Exception message: " (.getMessage e)))))
        (recur)))))

(defn message-dispatch [{:keys [topic payload sender] :as message}
                        {:keys [channel-connection-channels

             ;; If a result is accepted it should be sent to the
             ;; "Results Access" for handling.
             (async/>!! (:in-channel rules-engine-channels)
                        {:topic   (first payload)
                         :payload (second payload)}))
           [:file/import _]
           (let [[import import-ch] (async/alts!!
                                     [[(:in-channel file-handler-channels)
