funcatron.tron.brokers.shared
build-message
(build-message broker metadata payload ack-fn nack-fn)
Builds a message from the metadata and payload
close-all-listeners
(close-all-listeners mb)
Closes all the listeners for the MessageBroker
dispatch-wire-queue
multimethod
A multi-method that dispatches to the right queue provider/creator
listen-to-queue
(listen-to-queue broker queue func)
A helper function that wraps a Clojure function in a Function wrapper
wire-up-queue
(wire-up-queue)(wire-up-queue opts)
Based on the run-time options, wire up an appropriate message queue.