Ladder
Introduction
Ladder is a lightning fast persistent queue written in Java.
Usage
Installation
// TODO publish to Maven Central
Create persistent queue instance
String path = "/path/to/your/queue/dir";
Queue queue = new LadderQueue(
new File(path),
LadderQueueOptions.builder()
.dataFlushThreshold(512 * 1024)
.maxFileSize(100 * 1024)
.build()
);
Basic operations
put
byte[] data = new byte[] {...};
queue.put(data);
take
byte[] read = queue.take();
poll
long timeoutInMs = 500;
byte[] read = queue.poll(timeoutInMs);