capn-hook.durable
This namespace is all about the durable queues for the events streaming in the service. This will include the enqueueing, processing, and even the Datadog monitoriing of the queue sizes.
This namespace is all about the durable queues for the events streaming in the service. This will include the enqueueing, processing, and even the Datadog monitoriing of the queue sizes.
enqueue!clj
(enqueue! data)Function to enqueue the message on the default queue for processing. It will
return true if successful.
Function to enqueue the message on the default queue for processing. It will return `true` if successful.
flush!clj
(flush!)Function to remove all data stored in all queues we're currently managing. This will do so without any undo capability.
Function to remove all data stored in all queues we're currently managing. This will do so without any undo capability.
postclj
(post {c :created url :url msg :msg :as arg})Function to post the message out the url with the body of msg and if successful, return 'true'. If not, return 'false', and this will be put on the queue and retried.
Function to post the message out the url with the body of msg and if successful, return 'true'. If not, return 'false', and this will be put on the queue and retried.
process!clj
(process!)Function to process messages on the named queue until there is a timeout and then it will return the count of messages processed up to that point in time. This can then be called over and over again, as needed.
Function to process messages on the named queue until there is a timeout and then it will return the count of messages processed up to that point in time. This can then be called over and over again, as needed.
qnclj
This is the default queue name for all the callbacks that have to be sent to the registered callers. It's just here to simplify the code.
This is the default queue name for all the callbacks that have to be sent to the registered callers. It's just here to simplify the code.
cljdoc is a website building & hosting documentation for Clojure/Script libraries
× close