Liking cljdoc? Tell your friends :D

com.timezynk.useful.channel


*debug*clj


*reply-channel*clj


broker-loopclj

(broker-loop channel queue-id)

create-broker!clj

(create-broker! channel queue-id)

current-message-idclj


current-task-idclj


MessageTaskcljprotocol

processclj

(process task channel)

Process the message task

Process the message task

NUM_WORKERSclj


processed-messagesclj


publish!clj

(publish! channel context topic cname messages)

queue-sizeclj


route-messageclj

(route-message message channel message-counter)

start-channel!clj

(start-channel!)

subscribe-broadcastclj

(subscribe-broadcast topic collection-name f)

subscribe-request-responseclj

(subscribe-request-response topic collection-name f)

Subscribercljprotocol

publishclj

(publish this topic cname message reply-channel context)

Publish message to subscriber

Publish message to subscriber

subscribersclj


unsubscribe-allclj

(unsubscribe-all)

wait-forclj

(wait-for timeout-ms reply-channel)

cljdoc is a website building & hosting documentation for Clojure/Script libraries

× close