lib.rabbitmq

*default-exchanges*

dynamic

*default-options*

dynamic

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.

delete-queue

added in 4.1.4

(delete-queue mq name)

Deletes a queue 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-bindings

added in 4.1.4

(list-bindings mq)

Lists bindings grouped by source exchange.

list-consumers

added in 4.1.4

(list-consumers mq)

Lists consumers grouped by queue.

list-exchanges

added in 4.1.4

(list-exchanges mq)

Lists non-default exchanges in the current vhost.

list-queues

added in 4.1.4

(list-queues mq)

Lists queues in the current vhost.

network

added in 4.1.4

(network rabbitmq)

Returns the RabbitMQ network summary.

publish

added in 4.1.4

(publish mq exchange message)(publish mq exchange message opts)

Publishes a message to an exchange.

rabbit

added in 4.1.4

(rabbit)(rabbit m)

Creates a RabbitMQ client instance.

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.

vhost-encode

added in 4.1.4

(vhost-encode vhost)

Encodes a vhost for the management API.