Abstraction for media which transfer messages to subscribers. Subscription is done by declaring interest in a topic. Topics get published on the
Abstraction for media which transfer messages to subscribers. Subscription is done by declaring interest in a topic. Topics get published on the
(initialize this)
(publish this context topic collection messages)
Puts messages
on the channel.
Puts `messages` on the channel.
(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 is a website building & hosting documentation for Clojure/Script libraries
× close