bridg.sqs.component.sqs — bridg/sqs 0.2.5

Stateful SQS consumer.

ActivatedConsumer clj protocol

Protocol for finding the active consumer from a configured list.

active-consumer-component clj

(active-consumer-component this)

Finds the active consumer component in the system. Assumes that the component has the same name as the component key.

active-consumer-config clj

(active-consumer-config this)

Gets the config of he currently active consumer.

active-consumer-key clj

(active-consumer-key this)

Gets the key of the currently active consumer.

default-handler clj

(default-handler component queue-url sqs-result complete-fn extend-fn)

sqs clj

(sqs config)

sqs-response-wrapper clj

(sqs-response-wrapper component queue-url sqs-result p-atom)

Subscriber clj protocol

subscribe! clj

(subscribe! this)

Subscribes to a queue and polls for messages to dispatch to handle-fn.