Liking cljdoc? Tell your friends :D

com.moclojer.components.publisher


IPublishercljprotocol

archive!clj

(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!clj

(publish! this queue-name message)

start-job!clj

(start-job! this job)
source

mock-publisherclj

source

cljdoc is a website building & hosting documentation for Clojure/Script libraries

× close