Project

Namespaces

Public Vars

kithara.rabbitmq.consumer

cancel

(cancel {:keys [channel consumer-tag]})

Using the return value of consume, cancel the respective consumer.

view source

consume

(consume consumable consumer)(consume consumable opts consumer)

Consume from the given consumable. Options include:

  • :auto-ack? (defaults to true),
  • :local? (defaults to false),
  • :exclusive? (defaults to false),
  • :consumer-tag,
  • :arguments,
  • :queue-name (if the consumable is not bound to one).

Returns a map of :channel, :queue-name and :consumer-tag.

view source

from-fn

(from-fn f consumable & [opts])

Generate a consumer for the given consumable based on the given function. f will be called on a message map compatible with kithara’s ACK/NACK/REJECT functions and coercer options.

view source