Liking cljdoc? Tell your friends :D
Clojure only.
com.timezynk.useful.channel
*debug*clj
broker-loopclj
(broker-loop channel queue-id)create-broker!clj
(create-broker! channel queue-id)current-message-idclj
NUM_WORKERSclj
processed-messagesclj
publish!clj
(publish! channel topic cname messages)(publish! channel context topic cname messages)queue-sizeclj
route-messageclj
(route-message message message-counter queue-id)start-channel!clj
(start-channel!)subscribe-broadcastclj
(subscribe-broadcast topic collection-name f)subscribe-request-responseclj
(subscribe-request-response topic collection-name f)time-executingclj
time-in-queueclj
timed-out-messagesclj
unsubscribe-allclj
(unsubscribe-all)wait-forclj
(wait-for timeout-ms reply-channel)cljdoc is a website building & hosting documentation for Clojure/Script libraries
× close