common-clj.integrant-components.sqs-consumer — net.clojars.macielti/common-clj 29.58.61

commit-message-as-consumed! clj

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

consume! clj multimethod

Consumers clj

create-sqs-queues! clj

(create-sqs-queues! aws-credentials queues)

Inputs: [aws-credentials :- (s/pred map?) queues :- s/Str]

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]