lib.rabbitmq
adapt
added in 4.1.4
(adapt {:keys [function]} channel)Creates an adaptor for consuming input.
add-exchange
added in 4.1.4
(add-exchange mq name)(add-exchange mq name opts)Adds an exchange and returns the client.
add-queue
added in 4.1.4
(add-queue mq name)(add-queue mq name opts)Adds a queue and returns the client.
bind-exchange
added in 4.1.4
(bind-exchange mq source dest)(bind-exchange mq source dest opts)Creates an exchange binding and returns the client.
bind-queue
added in 4.1.4
(bind-queue mq source dest)(bind-queue mq source dest opts)Creates a queue binding and returns the client.
connect
added in 4.1.4
(connect {:keys [host port username password vhost heartbeat timeout recovery-interval topology-recovery]})Connects a consumer to the RabbitMQ instance.
consume
added in 4.1.4
(consume channel queue autoack tag {:keys [id], :as handler})Creates a consume function.
create-client
added in 4.1.4
(create-client)(create-client m)Creates a RabbitMQ management client.
delete-exchange
added in 4.1.4
(delete-exchange mq name)Deletes an exchange and returns the client.
install-vhost
added in 4.1.4
(install-vhost {:keys [vhost username], :as rabbitmq})Installs a vhost and adds user permissions.
list-exchanges
added in 4.1.4
(list-exchanges mq)Lists non-default exchanges in the current vhost.
publish
added in 4.1.4
(publish mq exchange message)(publish mq exchange message opts)Publishes a message to an exchange.
routing
added in 4.1.4
(routing mq)Returns the queue, exchange, and binding summary for a single vhost.
routing-all
added in 4.1.4
(routing-all rabbitmq opts)Lists routing information for all vhosts.