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
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.
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.
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.
cljdoc is a website building & hosting documentation for Clojure/Script libraries
× close