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

The public API.

get-all-processors clj

(get-all-processors)

Returns all registered systems in no particular order.

get-processor-by-queue-url clj

(get-processor-by-queue-url 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.

PipedProcessor 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 transform-fn
                   producer-parallelism consumer-parallelism acker-parallelism
                   nacker-parallelism blocking-consumers
                   queue-visibility-timeout-seconds]
            :as opts})

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

Returns an implementation of the PipedProcessor protocol which represents a message processing machine that can be started and stopped.

processors clj

start-all-processors! clj

(start-all-processors!)

Stop all running systems.

start-processor-by-queue-url! clj

(start-processor-by-queue-url! queue-url)

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

stop-all-processors! clj

(stop-all-processors!)

Stop all running systems. Systems are stopped concurrently for a faster return but this function blocks until they have all been fully shutdown.

stop-processor-by-queue-url! clj

(stop-processor-by-queue-url! queue-url)

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