(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.
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! url & [options])
Delete a queue. Not supported across all queue providers.
Delete a queue. Not supported across all queue providers.
(msg->birthdate url msg & [options])
Queues always place birthdates on messages if they are not already on them.
Queues always place birthdates on messages if they are not already on them.
(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.
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.
(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.
Convert a queue to a task sequence. Processors must call complete! on each task in order to remove it from the queue.
(seq->queue! url options data-seq)
Place a sequence into a queue. Blocking operation, exceptions are propagated to callers.
Place a sequence into a queue. Blocking operation, exceptions are propagated to callers.
(stats url & [options])
Retrieve information about the queue. Returns a map containing: :in-flight (required, integer) - Number of items in flight in the queue.
Retrieve information about the queue. Returns a map containing: :in-flight (required, integer) - Number of items in flight in the queue.
(take! url & [options])
Retrive a task from a queue
Retrive a task from a queue
(task->msg url task & [options])
Conversion of a task to a message
Conversion of a task to a message
cljdoc is a website building & hosting documentation for Clojure/Script libraries
× close