Abstraction for media which transfer messages to subscribers. Subscription is done by declaring interest in a topic. Topics get published on the bus, which routes them to eligible subscribers.
Abstraction for media which transfer messages to subscribers. Subscription is done by declaring interest in a topic. Topics get published on the bus, which routes them to eligible subscribers.
(destroy this)Releases all associated resources.
Releases all associated resources.
(eligible-for bus topic collection)Sequence of subscribers eligible for topic on collection.
Sequence of subscribers eligible for `topic` on `collection`.
(initialize this)(initialize this num-workers)(initialize this num-workers params)Acquires all associated resources.
Acquires all associated resources.
(length this)Number of enqueued messages.
Number of enqueued messages.
(publish this context topic collection messages)Puts messages on the bus.
Puts `messages` on the bus.
(subscribe this topic collection subscriber)Registers subscriber for topic on collection.
Registers `subscriber` for `topic` on `collection`.
(unsubscribe-all this)Unregisters all subscribers.
Unregisters all subscribers.
(create group)(wait-for timeout-ms reply-channel)Awaits responses on reply-channel.
Returns false on timeout.
Throws the caught exception on error.
Returns true otherwise.
Awaits responses on `reply-channel`. Returns `false` on timeout. Throws the caught exception on error. Returns `true` otherwise.
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 |