langohr.consumers — com.novemberain/langohr 5.5.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.

create-default clj

(create-default channel handlers)

Instantiates and returns a new consumer that handles various consumer life cycle events. Various handlers can be provided (per below):

:handle-consume-ok-fn => fn [consumer-tag] :handle-cancel-fn => fn [consumer-tag] :handle-cancel-ok-fn => fn [consumer-tag] :handle-recover-ok-fn => fn [consumer-tag] :handle-delivery-fn => fn [channel delivery-meta ^bytes body] :handle-shutdown-signal-fn => fn [tag, ShutdownSignalException]

See also langohr.basic/consume.

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.