(ack-message channel delivery-tag)
ACK the given message.
ACK the given message.
(bind-queue channel {:keys [queue exchange routing-key]})
Bind queue to exchange
Bind queue to exchange - skip for default exchange ''
(nack-message channel delivery-tag)
NACK the given message (message is requeued)!
NACK the given message (message is requeued)!
(publish-message channel {:keys [exchange routing-key body attempt options]})
Publish message bytes using provided channel. Publish to given exchange & routing-key. Options
Publish message bytes using provided channel. Publish to given exchange & routing-key. Options - mandatory (flag to ensure message delivery) - persistent? (flag to write message to disk) - attempt (set 'retry-attempts' header in message) - expiration (set message expiration)
cljdoc is a website building & hosting documentation for Clojure/Script libraries
× close