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

The public API.

create-system clj

(create-system {:keys [client-opts queue-url consumer-fn producer-parallelism
                       consumer-parallelism acker-parallelism nacker-parallelism
                       blocking-consumers transform]
                :as opts})

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.

get-system clj

(get-system queue-url)

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

http-client clj

(http-client http-opts)

Returns a http client using cognitect's async jetty client wrapper.

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