(archive! this queue-name message)
When a message is sent, but not received/read by any subscribers, we archive it in a separate queue and make sure to pop it when the subscriber is back on track. The created queue will be named pending.<queue-name>.
When a message is sent, but not received/read by any subscribers, we archive it in a separate queue and make sure to pop it when the subscriber is back on track. The created queue will be named pending.<queue-name>.
(publish! this queue-name message)
(start-job! this job)
cljdoc is a website building & hosting documentation for Clojure/Script libraries
× close