Liking cljdoc? Tell your friends :D
Clojure only.
com.timezynk.domain.mongo.channel
broadcastclj
destroyclj
(destroy)initclj
(init db)NUM_BROADCAST_WORKERSclj
NUM_PERSISTED_WORKERSclj
NUM_REQUEST_RESPONSE_WORKERSclj
persistedclj
put!clj
(put! topic cname & {:keys [new old context]})request-responseclj
subscribeclj
(subscribe topic f)(subscribe topic collection-name f)Add new request response subscriber to topic. Wait until response is sent before next message is sent. Topic can be an array of topic or just a single topic.
Add new request response subscriber to topic. Wait until response is sent before next message is sent. Topic can be an array of topic or just a single topic.
subscribe-broadcastclj
(subscribe-broadcast topic collection-name f)Add new request subscriber to topic. Messages are sent with lower priority and the next message is sent immediately. Topic can be an array of topic or just a single topic.
Add new request subscriber to topic. Messages are sent with lower priority and the next message is sent immediately. Topic can be an array of topic or just a single topic.
subscribe-persistedclj
(subscribe-persisted topic collection-name f)Adds f as subscriber to topic. Persists messages in the database
and manages them by means of a MongoDB queue.
topic may a scalar value or a collection.
Adds `f` as subscriber to `topic`. Persists messages in the database and manages them by means of a MongoDB queue. `topic` may a scalar value or a collection.
unsubscribe-allclj
(unsubscribe-all)WAIT_TIMEOUTclj
cljdoc is a website building & hosting documentation for Clojure/Script libraries
× close