              )
       )))
 
+
 (defn- get-task-object [topology component-id]
+  ;; TODO: this will be no longer necessary when constructing system topology in nimbus
   (if (= ACKER-COMPONENT-ID component-id)
     (mk-acker-bolt)
     (let [spouts (.get_spouts topology)

  (.emitDirect collector task stream values)
  )

(defn mk-acker-bolt []
  (let [output-collector (atom nil)
        pending (atom nil)]

(defmulti mk-task-stats class-selector)

(defn- get-readable-name [topology-context]
  (.getThisComponentId topology-context))

(defn- send-ack [^TopologyContext topology-context ^Tuple input-tuple
                 ^List generated-ids send-fn]
