langohr.consumers — com.novemberain/langohr 3.7.0

Functions that instantiate consumers and provide convenient ways of registering them.

Relevant guides:

• http://clojurerabbitmq.info/articles/queues.html

ack-unless-exception clj

(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 clj

(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 clj

(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 clj

(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 clj

(deliveries-seq qcs)

Builds a lazy seq of delivery instances from a queueing consumer.

subscribe clj

(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.