com.timezynk.domain.mongo.channel — com.timezynk/domain 1.6.7.3

channel clj

f-wrapper clj

(f-wrapper f)

handler-time clj

put! clj

(put! topic cname & {:keys [new old context]})

subscribe clj

(subscribe topic f)

(subscribe topic collection-name f)

Add new request response subscriber to topic. Wait until response is sent before next message is sent. Topic can be an array of topic or just a single topic.

subscribe-broadcast clj

(subscribe-broadcast topic collection-name f)

Add new request subscriber to topic. Messages are sent with lower priority and the next message is sent immediately. Topic can be an array of topic or just a single topic.

unsubscribe-all clj

(unsubscribe-all)

WAIT_TIMEOUT clj