Node-local delivery: resolve a routing envelope to the local node's ws adapters and send. Built as a closure over the local registry + pubsub manager; registered with a message bus via start-subscriber!. Never calls service send methods (no re-publish recursion).
Node-local delivery: resolve a routing envelope to the local node's ws adapters and send. Built as a closure over the local registry + pubsub manager; registered with a message bus via start-subscriber!. Never calls service send methods (no re-publish recursion).
(make-delivery-fn registry pubsub-manager)Return (fn [envelope] -> int): deliver the envelope's :message to every open local adapter it resolves to, and to every in-process handler subscribed to it; return how many recipients there were.
The count includes service handlers. A topic with three handlers and no open
sockets returns 3, not 0 — publish-to-topic returning zero while three
subscribers ran would describe something other than what happened.
Return (fn [envelope] -> int): deliver the envelope's :message to every open local adapter it resolves to, and to every in-process handler subscribed to it; return how many recipients there were. The count includes service handlers. A topic with three handlers and no open sockets returns 3, not 0 — `publish-to-topic` returning zero while three subscribers ran would describe something other than what happened.
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 |