rabbitmq.component.consumer — net.clojars.macielti/rabbitmq 0.2.3

consumed-count clj

(consumed-count {:keys [consumed-count]})

Returns the number of consumed messages in test environment. Returns nil in production environment.

Consumers clj

handler-fn->interceptor clj

(handler-fn->interceptor handler-fn)

wait-for-consumption! clj

(wait-for-consumption! consumer
                       expected-count
                       &
                       {:keys [timeout-ms] :or {timeout-ms 10000}})

Waits until the number of consumed messages reaches the expected count. Useful in integration tests to ensure all produced messages have been consumed before proceeding with assertions. Options: :timeout-ms - Maximum time to wait in milliseconds (default: 10000)