com.moclojer.components.consumer — com.moclojer/components 0.0.4

create-pubsub clj

(create-pubsub components workers)

group-work-handlers-by-qname clj

(group-work-handlers-by-qname workers)

IConsumer clj protocol

safely-subscribe-workers clj

(safely-subscribe-workers this conn pubsub qnames cur-try)

subscribe-workers clj

(subscribe-workers this conn components workers blocking?)

unarchive-queue! clj

(unarchive-queue! this conn qname on-msg-fn)