Liking cljdoc? Tell your friends :D

common-clj.integrant-components.sqs-consumer


commit-message-as-consumed!clj

(commit-message-as-consumed! message consumed-messages)
source

consume!cljmultimethod

source

Consumersclj

source

create-sqs-queues!clj

(create-sqs-queues! queues)

Inputs: [queues :- [s/Str]]

Inputs: [queues :- [s/Str]]
sourceraw docstring

ensure-consumers-threads-are-up!clj

(ensure-consumers-threads-are-up! consumers-thread-pool
                                  switch
                                  consumers
                                  components)
source

fetch-messages-waiting-to-be-processed!clj

(fetch-messages-waiting-to-be-processed! queue
                                         produced-messages
                                         consumed-messages)

Inputs: [queue :- s/Str produced-messages consumed-messages]

Inputs: [queue :- s/Str produced-messages consumed-messages]
sourceraw docstring

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

× close