goose.brokers.rmq.broker
Closecljprotocol
Closes connection to RabbitMQ Message Broker.
Closes connection to RabbitMQ Message Broker.
closeclj
(close this)default-optsclj
Map of sample config for RabbitMQ Message Broker.
Keys
: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-consumerclj
(new-consumer 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
(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-producerclj
(new-producer opts)(new-producer {:keys [queue-type publisher-confirms] :as opts} channels)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
(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