com.timezynk.useful.channel — com.timezynk/useful 2.2.0

*debug* clj

broker-loop clj

(broker-loop channel queue-id)

create-broker! clj

(create-broker! channel queue-id)

current-message-id clj

NUM_WORKERS clj

processed-messages clj

publish! clj

(publish! channel topic cname messages)

(publish! channel context topic cname messages)

queue-size clj

route-message clj

(route-message message message-counter)

start-channel! clj

(start-channel!)

subscribe-broadcast clj

(subscribe-broadcast topic collection-name f)

subscribe-request-response clj

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

unsubscribe-all clj

(unsubscribe-all)

wait-for clj

(wait-for timeout-ms reply-channel)