Closes connection to RabbitMQ Message Broker.
Closes connection to RabbitMQ Message Broker.
(close this)
Map of sample config for RabbitMQ Message Broker.
:settings
: Map of settings accepted by langohr.core/settings
.
Connecting to RabbitMQ using Langohr
:queue-type
: classic
or quorum
(for replication purpose).
Example : goose.brokers.rmq.queue/classic
, goose.brokers.rmq.queue/quorum
:publisher-confirms
: Strategy for RabbitMQ Publisher Confirms.
Wiki & Tutorial : Publisher Confirms wiki, Publisher Confirms tutorial
Example : goose.brokers.rmq.publisher-confirms/sync
, goose.brokers.rmq.publisher-confirms/async
:return-listener
: Handle unroutable messages.
Receives a map of keys :reply-code
:reply-text
:exchange
:routing-key
:properties
:body
.
Example : goose.brokers.rmq.return-listener/default
:shutdown-listener
: Handle abrupt RabbitMQ connection shutdowns not initialized by application.
Example : goose.brokers.rmq.shutdown-listener/default
Map of sample config for RabbitMQ Message Broker. ### Keys `:settings` : Map of settings accepted by `langohr.core/settings`.\ [Connecting to RabbitMQ using Langohr](http://clojurerabbitmq.info/articles/connecting.html) `:queue-type` : `classic` or `quorum` (for replication purpose).\ Example : [[goose.brokers.rmq.queue/classic]], [[goose.brokers.rmq.queue/quorum]] `:publisher-confirms` : Strategy for RabbitMQ Publisher Confirms.\ Wiki & Tutorial : [Publisher Confirms wiki](https://www.rabbitmq.com/confirms.html#publisher-confirms), [Publisher Confirms tutorial](https://www.rabbitmq.com/tutorials/tutorial-seven-java.html)\ Example : [[goose.brokers.rmq.publisher-confirms/sync]], [[goose.brokers.rmq.publisher-confirms/async]] `:return-listener` : Handle unroutable messages.\ Receives a map of keys `:reply-code` `:reply-text` `:exchange` `:routing-key` `:properties` `:body`.\ Example : [[goose.brokers.rmq.return-listener/default]] `:shutdown-listener` : Handle abrupt RabbitMQ connection shutdowns not initialized by application.\ Example : [[goose.brokers.rmq.shutdown-listener/default]]
(new-consumer opts)
Creates a RabbitMQ broker implementation for worker.
opts
: Map of :settings
, :queue-type
, :publisher-confirms
, :return-listener
, :shutdown-listener
.
Example : default-opts
(new-consumer rmq-opts)
Creates a RabbitMQ broker implementation for worker. ### Args `opts` : Map of `:settings`, `:queue-type`, `:publisher-confirms`, `:return-listener`, `:shutdown-listener`.\ Example : [[default-opts]] ### Usage ```Clojure (new-consumer rmq-opts) ``` - [RabbitMQ Message Broker wiki](https://github.com/nilenso/goose/wiki/RabbitMQ)
(new-producer opts)
(new-producer {:keys [queue-type publisher-confirms] :as opts} channels)
Creates a RabbitMQ broker implementation for client.
opts
: Map of :settings
, :queue-type
, :publisher-confirms
, :return-listener
, :shutdown-listener
.
Example : default-opts
channels
: Count of channel-pool-size for publishing messages.
(new-producer rmq-opts)
Creates a RabbitMQ broker implementation for client. ### Args `opts` : Map of `:settings`, `:queue-type`, `:publisher-confirms`, `:return-listener`, `:shutdown-listener`.\ Example : [[default-opts]] `channels` : Count of channel-pool-size for publishing messages. ### Usage ```Clojure (new-producer rmq-opts) ``` - [RabbitMQ Message Broker wiki](https://github.com/nilenso/goose/wiki/RabbitMQ)
cljdoc is a website building & hosting documentation for Clojure/Script libraries
× close