com.timezynk.useful.channel — com.timezynk/useful 1.19.1

*debug* clj

*reply-channel* clj

broker-loop clj

(broker-loop channel queue-id)

create-broker! clj

(create-broker! channel queue-id)

current-message-id clj

current-task-id clj

MessageTask clj protocol

process clj

(process task channel)

Process the message task

NUM_WORKERS clj

processed-messages clj

publish! clj

(publish! channel context topic cname messages)

queue-size clj

route-message clj

(route-message message channel 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)

Subscriber clj protocol

publish clj

(publish this topic cname message reply-channel context)

Publish message to subscriber

subscribers clj

unsubscribe-all clj

(unsubscribe-all)

wait-for clj

(wait-for timeout-ms reply-channel)