(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/PipedSystem protocol so that the associated system can easily be started and stopped. For supported attributes see piped.core/create-system.
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.
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/PipedSystem protocol so that the associated system can easily be started and stopped. For supported attributes see piped.core/create-system. 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 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.
Like defmultiprocessor, but defines a single message handling implementation instead of requiring defining a dynamic dispatch function and separate method implementation.
cljdoc is a website building & hosting documentation for Clojure/Script libraries
× close