Namespaces

Public Vars

langohr.http

RabbitMQ HTTP API client.

Relevant documentation guides:

* http://www.rabbitmq.com/management.html
* https://raw.githack.com/rabbitmq/rabbitmq-management/rabbitmq_v3_5_6/priv/www/api/index.html

*default-http-options*

dynamic

*endpoint*
dynamic
*password*
dynamic
*username*
dynamic
add-user
(add-user user password tags)(add-user user password tags m)
add-vhost
(add-vhost vhost)(add-vhost vhost m)
aliveness-test
(aliveness-test vhost)
bind
(bind vhost exchange queue)(bind vhost exchange queue properties)(bind vhost exchange queue properties m)
close-connection
(close-connection id)(close-connection id m)
close-connections-from
(close-connections-from user)(close-connections-from user m)
connect!
(connect! endpoint username password)(connect! endpoint username password opts)
declare-exchange
(declare-exchange vhost exchange properties)
declare-permissions
deprecated
(declare-permissions vhost username {:keys [configure write read], :as body})
Deprecated. Use set-permissions.

declare-policy
deprecated
(declare-policy vhost name policy)
Deprecated. Use set-policy.

declare-queue
(declare-queue vhost queue properties)
declare-user
deprecated
(declare-user user password tags)
Deprecated. Use add-user.

declare-vhost
deprecated
(declare-vhost vhost)
Deprecated. Use add-vhost.

delete-exchange
(delete-exchange vhost exchange)(delete-exchange vhost exchange m)
delete-permissions
(delete-permissions vhost username)
delete-policy
(delete-policy vhost)
delete-queue
(delete-queue vhost queue)(delete-queue vhost queue m)
delete-user
(delete-user user)(delete-user user m)
delete-vhost
(delete-vhost vhost)(delete-vhost vhost m)
get-connection
(get-connection id)(get-connection id m)
get-exchange
(get-exchange vhost exchange)
get-message
(get-message vhost queue)
get-node
(get-node)(get-node node m)
get-overview
(get-overview)(get-overview m)
get-permissions
(get-permissions vhost username)(get-permissions vhost username m)
get-policies
(get-policies vhost)(get-policies vhost name)
get-queue
(get-queue vhost queue)
get-user
(get-user user)(get-user user m)
get-vhost
(get-vhost vhost)(get-vhost vhost m)
list-bindings
(list-bindings)(list-bindings vhost)(list-bindings vhost queue)(list-bindings vhost queue m)
list-bindings-for-which-exchange-is-the-destination
(list-bindings-for-which-exchange-is-the-destination vhost exchange)
list-bindings-for-which-exchange-is-the-source
(list-bindings-for-which-exchange-is-the-source vhost exchange)
list-channels
(list-channels)(list-channels m)
list-connections
(list-connections)(list-connections m)
list-connections-from
(list-connections-from user)(list-connections-from user m)
list-definitions
(list-definitions)(list-definitions m)
list-enabled-protocols
(list-enabled-protocols)(list-enabled-protocols m)
list-exchanges
(list-exchanges)(list-exchanges vhost)
list-extensions
(list-extensions)(list-extensions m)
list-nodes
(list-nodes)(list-nodes m)
list-permissions
(list-permissions)(list-permissions vhost)(list-permissions vhost m)
list-policies
(list-policies)
list-queues
(list-queues)(list-queues vhost)(list-queues vhost m)
list-users
(list-users)(list-users m)
list-vhosts
(list-vhosts)(list-vhosts m)
protocol-ports
(protocol-ports)(protocol-ports m)
publish
(publish vhost exchange)
purge-queue
(purge-queue vhost queue)(purge-queue vhost queue m)
safe-json-decode
(safe-json-decode {body :body, {content-type "content-type"} :headers})
Try to parse json response. If the content-type is not json, just return the body (string).

set-permissions
(set-permissions vhost username {:keys [configure write read], :as options})
set-policy
(set-policy vhost name policy)
throw-exceptions
url-with-path
(url-with-path path)
user-exists?
(user-exists? user)(user-exists? user m)
vhost-exists?
(vhost-exists? vhost)(vhost-exists? vhost m)
whoami
(whoami)