kithara.rabbitmq.queue
AMQPQueue
protocol
members
bind
(bind queue {:keys [exchange routing-keys arguments]})Bind the queue to the given routing keys on the given exchange.
get
(get queue {:keys [auto-ack? as], :or {auto-ack? true, as :bytes}})Retrieve a single message from the queue.
declare
(declare channel)(declare channel queue-name & [{:keys [durable? exclusive? auto-delete? arguments], :or {exclusive? true, auto-delete? true, durable? false}}])Declare a new RabbitMQ queue. Note that, for named queues, options have to match the potentially already existing queue.