tech.queue — techascent/tech.queue 0.1.2

*static-queue-options* clj

*url-parts->queue* clj

complete! clj

(complete! url task & [options])

Complete a task. Tasks, once taken, are only temporarily invisible. In order to remove a task from a queue it must be successfully completed.

delete-queue! clj

(delete-queue! url & [options])

Delete a queue. Not supported across all queue providers.

msg->birthdate clj

(msg->birthdate url msg & [options])

Queues always place birthdates on messages if they are not already on them.

pmap-queue clj

(pmap-queue url num-threads processing-fn & [options])

Create an infinite sequence of results of reading from the queue. Tasks that fail to process will be reprocessed according to the visibility timeout member of options. See protocols.clj.

Result will be infinite unless the queue itself gets deleted.

put! clj

(put! url msg & [options])

Place a msg in a queue

queue->task-seq-details clj

(queue->task-seq-details url
                         {:keys [receive-message-wait-time-seconds]
                          :or {receive-message-wait-time-seconds 10}
                          :as options})

Convert a queue to a task sequence. Processors must call complete! on each task in order to remove it from the queue.

seq->queue! clj

(seq->queue! url options data-seq)

Place a sequence into a queue. Blocking operation, exceptions are propagated to callers.

stats clj

(stats url & [options])

Retrieve information about the queue. Returns a map containing: :in-flight (required, integer) - Number of items in flight in the queue.

take! clj

(take! url & [options])

Retrive a task from a queue

task->msg clj

(task->msg url task & [options])

Conversion of a task to a message