langohr.consumers
ack-unless-exception
(ack-unless-exception f)
Wrapper for delivery handlers which auto-acks messages.
This differs from `:auto-ack true', which tells the broker to
consider messages acked upon delivery. This explicitly acks, as
long as the consumer function doesn't throw an exception.
blocking-subscribe
(blocking-subscribe ch queue f)(blocking-subscribe channel queue f options)
Adds new a QueueingConsumer to a queue using the basic.consume AMQP 0.9.1 method
create-default
(create-default channel {:keys [handle-consume-ok-fn handle-cancel-fn handle-cancel-ok-fn handle-shutdown-signal-fn handle-recover-ok-fn handle-delivery-fn]})
Instantiates and returns a new consumer that handles various consumer life cycle events. See also langohr.basic/consume.
create-queueing
(create-queueing channel {:keys [handle-consume-ok-fn handle-cancel-ok-fn handle-recover-ok-fn handle-delivery-fn]})
Instantiates and returns a new queueing consumer that handles various consumer life cycle events. See also langohr.basic/consume.
Consumer tag must be unique per queue. By default it will be generated by RabbitMQ and thus
guaranteed to be unique.
deliveries-seq
(deliveries-seq qcs)
Builds a lazy seq of delivery instances from a queueing consumer.
subscribe
(subscribe ch queue f)(subscribe ch queue f options)
Adds a new default consumer to a queue using the basic.consume AMQP 0.9.1 method.
Consumer-related options will be passed to `create-default`. Consumer tag
must be unique per queue. By default it will be generated by RabbitMQ and thus
guaranteed to be unique.