piped.core — org.clojars.rutledgepaulv/piped 0.1.0

The public API.

create-system clj

(create-system {:keys [client queue-url consumer-fn] :as attrs})

(create-system client queue-url consumer-fn)

(create-system client
               queue-url
               consumer-fn
               {:keys [producer-parallelism consumer-parallelism
                       acker-parallelism nacker-parallelism blocking-consumers
                       transform]
                :or {producer-parallelism 1
                     consumer-parallelism 10
                     acker-parallelism 2
                     nacker-parallelism 2
                     blocking-consumers true}})

Spawns a set of producers and consumers for a given queue.

Returns a function of no arguments that can be called to stop the system.

default-client clj

(default-client)

Returns an AWS client instance.

default-transform clj

(default-transform message)

A function that parses a message body as edn data

get-system clj

(get-system queue-url)

Gets the system for a given queue url. Returns nil if there is no such system.

PipedSystem clj protocol

running? clj

(running? this)

Is the system currently running?

start clj

(start this)

Start polling SQS and processing messages.

stop clj

(stop this)

Stop the system and await completion of in-flight messages.

start-all-systems clj

(start-all-systems)

Stop all running systems.

start-system clj

(start-system queue-url)

For a given queue-url, start the associated system (if any).

stop-all-systems clj

(stop-all-systems)

Stop all running systems.

stop-system clj

(stop-system queue-url)

For a given queue-url, stop the associated system (if any).

systems clj