durable-queue
durable-queue copied to clipboard
clj-commons
a disk-backed queue for clojure
Fix entailed added type hints to resolve breaking code. All unit tests pass. No reflection errors in core ns. I did not update project dependencies to minimize project changes but...
This library has been a workhorse across java updates. It looks like a bit of work will be required to maintain dependability with the release of java 13 which touched...
I assume this is a version conflict, either of Java or Clojure or durable-queue. My code works fine on my local Macbook Pro, but I created a new EC2 instance...
System/currentTimeMillis is not guaranteed to progress monotonically. NTP shifts, leap seconds, and manual system time changes can all cause elapsed time calculations to be incorrect if you use currentTimeMillis. nanoTime...
The README contains documentation for these parameters, this commit copies them from the README into the docstring.
This function lets the client delete an individual named queue, besides just all of the data. Useful for deleting corrupted queue files (such as that get created when the disk...
An imperfect solution to issue #18, but better than application failure. It looks like a significant effort to re-design the program to prevent the slab files from overflowing in the...
In the put! function, slab! is called before queue!, writing the data to the slab before offering to the queue. ```clj (if-let [val (locking q (queue! (vary-meta (slab!) assoc ::this...
I'm not sure if this is as expected, but I found this behavior when I was trying stuff in REPL. ``` clojure > (dq/put! q :test "test task") > (def...
