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

The public API.

get-all-systems clj

(get-all-systems)

Returns all registered systems in no particular order.

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.

processor clj

(processor {: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 an implementation of the PipedSystem protocol which represents a system that can be started and stopped.

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