durable-queue
durable-queue copied to clipboard
clj-commons
a disk-backed queue for clojure
Hi, Should we consider put! and take! threadsafe? I have one thread doing puts in bursts at regular interval, and N workers on their own respective threads consuming the queue....
[Question] Here's one I see in my process. "out" {:enqueued 8332, :retried 0, :completed 8333, :in-progress -1} I'm unsure how to handle this, as I depend on the values to...
I've noticed an _annoying_ issue that seems like it might be avoidable. Let's say that I'm using durable-queue in a project: ```clojure (defonce q (queues "/tmp" {})) ``` and then...
I'm starting to work with this library and Clojure 1.8.0, and as-is, this isn't working well - but if I preload the `byte-streams` v0.2.2 and `exclude` that from `durable-queues`, then...
I had another process writing temporary files with names matching `#"\w+_\d+"` (2015_05_01_xxxxxx.zip) to the same `./tmp` directory where durable-queue stored its slabs. After a while, I noticed those temporary files...
Hey @ztellman. Thanks for the awesome library! I noticed that queue names with dashes are automatically converted to underscores. Intentional? ``` clojure (def dir "/tmp") (def conn (d/queues dir {}))...
Specifically: https://github.com/Factual/durable-queue/blob/master/src/durable_queue.clj#L731 It looks like `put!` will always evaluate to nil, not to true/false based on whether or not the put times out.
Would it be possible to create a version of the queue that would not be durable for testing purposes? Maybe you could pass an optional parameter to set it to...
This PR builds on top of clj-commons/durable-queue#27 , which should be reviewed and merged in first. In this PR, I have done the following work: 1. Update the directory structure...
This PR (and the master branch on my fork) contains (almost) all the fixes contributed by different members of the community. The only PR I haven't picked is #19 ,...