common-clj.integrant-components.sqs-consumer

Liking cljdoc? Tell your friends :D

Clojure only.

commit-message-as-consumed!
consume!
Consumers
create-sqs-queues!
ensure-consumers-threads-are-up!
fetch-messages-waiting-to-be-processed!

commit-message-as-consumed!^clj

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

source

consume!^cljmultimethod

source

Consumers^clj

source

create-sqs-queues!^clj

(create-sqs-queues! queues)

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

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

source raw 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]

source raw docstring

cljdoc builds & hosts documentation for Clojure/Script libraries

Keyboard shortcuts

`Ctrl`+`k`	Jump to recent docs
`←`	Move to previous article
`→`	Move to next article
`Ctrl`+`/`	Jump to the search field

Raise an issue Browse cljdoc source Chat on Slack

× close

common-clj.integrant-components.sqs-consumer

commit-message-as-consumed!clj

consume!cljmultimethod

Consumersclj

create-sqs-queues!clj

ensure-consumers-threads-are-up!clj

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

commit-message-as-consumed!^clj

consume!^cljmultimethod

Consumers^clj

create-sqs-queues!^clj

ensure-consumers-threads-are-up!^clj

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