bunnicula.client.rabbitmq.channel

Liking cljdoc? Tell your friends :D

Clojure only.

ack-message
bind-queue
close
create
declare-exchange
declare-queue
default-routing-key
nack-message
open?
publish-message

ack-message^clj

(ack-message channel delivery-tag)

ACK the given message.

ACK the given message.

source raw docstring

bind-queue^clj

(bind-queue channel {:keys [queue exchange routing-key]})

Bind queue to exchange

skip for default exchange ''

Bind queue to exchange
- skip for default exchange ''

source raw docstring

close^clj

(close channel)

source

create^clj

(create connection)

(create connection prefetch-count)

source

declare-exchange^clj

(declare-exchange channel {:keys [options name type]})

source

declare-queue^clj

(declare-queue channel {:keys [name options]})

source

default-routing-key^clj

source

nack-message^clj

(nack-message channel delivery-tag)

NACK the given message (message is requeued)!

NACK the given message (message is requeued)!

source raw docstring

open?^clj

(open? channel)

source

publish-message^clj

(publish-message channel {:keys [exchange routing-key body attempt 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)

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)

source raw docstring