Liking cljdoc? Tell your friends :D

ziggurat.messaging.rabbitmq-wrapper


connectionclj

source

consume-messageclj

(consume-message ch meta payload ack?)
source

create-and-bind-queueclj

(create-and-bind-queue queue-name exchange-name)
(create-and-bind-queue queue-name exchange-name dead-letter-exchange)
source

get-connectionclj

(get-connection)
source

get-messages-from-queueclj

(get-messages-from-queue queue-name ack?)
(get-messages-from-queue queue-name ack? count)
source

process-messages-from-queueclj

(process-messages-from-queue queue-name count processing-fn)
source

publishclj

(publish exchange message-payload)
(publish exchange message-payload expiration)
source

start-connectionclj

(start-connection config stream-routes)
source

start-subscriberclj

(start-subscriber prefetch-count wrapped-mapper-fn queue-name)
source

stop-connectionclj

(stop-connection config stream-routes)
source

cljdoc is a website building & hosting documentation for Clojure/Script libraries

× close