Liking cljdoc? Tell your friends :D

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