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


;; Provides useful Timbre aliases in this ns
(log/refer-timbre)

(defn start-result-rules-engine [in-ch out-ch]
  (async/go-loop []

            (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
