(destroy)(init db)(put! topic cname & {:keys [new old context]})(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-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-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-all)cljdoc builds & hosts documentation for Clojure/Script libraries
| Ctrl+k | Jump to recent docs |
| ← | Move to previous article |
| → | Move to next article |
| Ctrl+/ | Jump to the search field |