Liking cljdoc? Tell your friends :D

langohr.consumers

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

Relevant guides:

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

Relevant guides:

* http://clojurerabbitmq.info/articles/queues.html
raw docstring

ack-unless-exceptionclj

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

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.
sourceraw docstring

create-defaultclj

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

Instantiates and returns a new consumer that handles various consumer life cycle events. See also langohr.basic/consume.
sourceraw docstring

subscribeclj

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

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.
sourceraw docstring

cljdoc is a website building & hosting documentation for Clojure/Script libraries

× close