piped.sweet — org.clojars.rutledgepaulv/piped 0.1.11

defmultiprocessor clj macro

(defmultiprocessor symbol bindings attributes & body)

Defines a clojure multimethod and constructs a new piped system from the attribute map. The multimethod is used as the consumer function for processing the queue. Multimethod var implements the piped.core/PipedProcessor protocol so that the associated system can easily be started and stopped. For supported attributes see piped.core/processor.

Redefining a processor for the same queue will stop the system for the old queue and start a new system using the most recent attributes. If the system was not running neither will the new system be running.

Changing the queue-url for a processor will stop the system for the old queue-url and the new system for the new queue-url won't be started automatically.

Unlike clojure.core/defmulti you may redefine the dispatch function without ceremony.

defprocessor clj macro

(defprocessor symbol bindings attributes & body)

Like defmultiprocessor, but defines a single message handling implementation instead of requiring defining a dynamic dispatch function and separate method implementation for cases when you have a heterogeneous message type or existing dispatch functions.