aws-client-component.sqs.consumer — net.clojars.macielti/aws-client-component 1.1.1

commit-message-as-consumed! clj

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

consume! clj multimethod

Consumers clj

ensure-consumers-threads-are-up! clj

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

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]