langohr.queue — com.novemberain/langohr 5.1.0

Functions that provide operations on queues.

Relevant guides:

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

bind clj

(bind ch queue exchange)

(bind ch
      queue
      exchange
      {:keys [routing-key arguments] :or {routing-key "" arguments nil}})

Binds a queue to an exchange using queue.bind AMQP method

consumer-count clj

(consumer-count ch queue)

Returns a number of active consumers on the queue

declare clj

(declare ch)

(declare ch queue)

(declare ch
         queue
         {:keys [durable exclusive auto-delete arguments]
          :or {durable false exclusive false auto-delete true}})

Actively declare a server-named or named queue using queue.declare AMQP method.

Usage example:

;; declare server-named, exclusive, autodelete, non-durable queue.
(lhq/declare channel) ;; will return a map that contains the name: {:queue "amq.gen-QtE7OdDDjlHcxNGWuSoUb3"}

;; creates named non-durable, exclusive, autodelete queue
(lhq/declare channel queue-name {:durable false :exclusive true :auto-delete true})

Options

:durable (default: false): indicates wether the queue is durable. Durable queue will survive server restart. Durable queues do not neccessarily hold persistent messages. Using persistent messages with transient queues is allowed, but will not save messages between restarts. :exclusive (default: false): when set to true, indicates that the queue is exclusive. No other subscriber can consume form that queue. Exclusive always implies auto-delete, as messages are delivered to the single consumer. When set to false, allows multiple consumers. :auto-delete (default: true): when set to true, queue will be purged as soon as last consumer stops is finished using it. If consumer never got attached to the queue, it won't get deleted.

:arguments: other properties for the Queue.

declare-passive clj

(declare-passive ch queue)

Declares a queue passively (checks that it is there) using queue.declare AMQP method

declare-server-named clj

(declare-server-named ch)

(declare-server-named ch
                      {:keys [durable exclusive auto-delete arguments]
                       :or {durable false exclusive false auto-delete true}})

Declares a server-named queue and returns its name.

delete clj

(delete ch queue)

(delete ch queue if-unused if-empty)

Deletes a queue using queue.delete AMQP method

empty? clj

(empty? ch queue)

Returns true if queue is empty (has no messages ready), false otherwise

message-count clj

(message-count ch queue)

Returns a number of messages that are ready for delivery (e.g. not pending acknowledgements) in the queue

purge clj

(purge ch queue)

Purges a queue using queue.purge AMQP method

status clj

(status ch queue)

Returns a map with two keys: message-count and :consumer-count, for the given queue. Uses queue.declare AMQP method with the :passive attribute set.

unbind clj

(unbind ch queue exchange)

(unbind ch queue exchange routing-key)

(unbind ch queue exchange routing-key arguments)

Unbinds a queue from an exchange using queue.bind AMQP method