tech.queue.task — techascent/tech.queue 1.0

Generic things that can be executed on the queue. Uses keyword dispatch

add-processor-to-msg clj

(add-processor-to-msg task-obj-constructor-var msg)

forward-queue-processor clj

(forward-queue-processor process-fn
                         &
                         {:keys [log-context-fn ready-fn retire-fn
                                 resource-map-fn]})

keyword->fn clj

(keyword->fn kwd)

msg->task-object clj

(msg->task-object context msg)

put! clj

(put! queue constructor-var msg options)

task-processor clj

(task-processor context
                &
                {:keys [dispatch-fn] :or {dispatch-fn msg->task-object}})

var->keyword clj

(var->keyword var)

Given a var, make a keyword that points to it