goose.brokers.rmq.broker
Closecljprotocol
Close connections for RabbitMQ broker.
Close connections for RabbitMQ 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 : [[rmq-queue/classic]], [[rmq-queue/quorum]]
:publisher-confirms : Strategy for RabbitMQ Publisher Confirms.
Publisher Confirms wiki
:return-listener : Handle unroutable messages.
Example : return-listener/default
:shutdown-listener : Handle abrupt shutdowns not initialized by application.
Example : 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 : [[rmq-queue/classic]], [[rmq-queue/quorum]] `:publisher-confirms` : Strategy for RabbitMQ Publisher Confirms.\ [Publisher Confirms wiki](https://www.rabbitmq.com/confirms.html#publisher-confirms) `:return-listener` : Handle unroutable messages.\ Example : [[return-listener/default]] `:shutdown-listener` : Handle abrupt shutdowns not initialized by application. Example : [[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