lib.rabbitmq.consumer

(adapt {:keys [function]} channel)

Creates an adaptor for consuming input.

(connect {:keys [host port username password vhost heartbeat timeout recovery-interval topology-recovery]})

Connects a consumer to the RabbitMQ instance.

(consume channel queue autoack tag {:keys [id], :as handler})

Creates a consume function.

Generated by Codox