com.github.ivarref.yoltq.test-queue — com.github.ivarref/yoltq 0.2.85

bootstrap-poller! clj

(bootstrap-poller! txq running? poller-exited? bootstrapped? conn)

call-with-virtual-queue! clj

(call-with-virtual-queue! f)

consume! clj macro

(consume! queue-name)

consume-expect! clj macro

(consume-expect! queue-name expected-status)

contains-queue-job? clj

(contains-queue-job? queue-id
                     conn
                     {:com.github.ivarref.yoltq/keys [id queue-name status]
                      :as m})

force-retry! clj macro

(force-retry! queue-name)

get-tx-q-job clj

(get-tx-q-job q-id)

put! clj

(put! q payload)

run-one-report-queue! clj

(run-one-report-queue!)

run-queue-once! clj

(run-queue-once! q status)

run-report-queue! clj

(run-report-queue! min-items)

transact-result->maps clj

(transact-result->maps {:keys [tx-data db-after]})

with-virtual-queue! clj macro

(with-virtual-queue! & body)