StorageConfig config = StorageConfig.newBuilder("/tmp/my-queue")
    .withDurableWrites(false)  // Fast writes
    .build();

try (JobQueue<String> queue = new RocksJobQueue<>(config, new StringCodec())) {
    // Enqueue a job
    long now = System.currentTimeMillis();
    queue.enqueue("job-1", "Process payment", now, 3);

    // Worker acquires and processes
    Job<String> job = queue.acquire("worker-1", 30000);
    if (job != null) {
        System.out.println("Processing: " + job.getPayload());
        queue.acknowledge(job);
    }
}

try (PersistentQueue<String> queue = new RocksPersistentQueue<>(
        config, new StringCodec(), "worker-1")) {

    queue.offer("Task 1");
    queue.offer("Task 2");

    String task = queue.poll();  // Returns "Task 1"
}

long now = System.currentTimeMillis();

// Execute immediately
queue.enqueue("email-1", emailData, now, 3);

// Execute in 1 hour
queue.enqueue("reminder-1", reminderData, now + 3600000, 3);

Job<String> job = queue.acquire("worker-1", 30000);

try {
    processJob(job.getPayload());
    queue.acknowledge(job);  // Success
} catch (Exception e) {
    queue.reject(job, e.getMessage());  // Will retry if attempts < max
}

QueueWorker<String> worker1 = QueueWorker.builder("worker-1", queue, processor)
    .withLeaseDuration(30000)
    .withPollInterval(1000)
    .build();

worker1.start();

public class EmailTask {
    private String recipient;
    private String subject;
    private String body;
}

JsonCodec<EmailTask> codec = new JsonCodec<>(EmailTask.class);
JobQueue<EmailTask> queue = new RocksJobQueue<>(config, codec);

EmailTask email = new EmailTask("user@example.com", "Welcome", "Hello!");
queue.enqueue("email-1", email, System.currentTimeMillis(), 3);

KryoCodec<OrderEvent> codec = new KryoCodec<>(OrderEvent.class);
JobQueue<OrderEvent> queue = new RocksJobQueue<>(config, codec);

OrderEvent order = new OrderEvent("ORD-123", items, metadata);
queue.enqueue("order-1", order, System.currentTimeMillis(), 3);

StorageConfig config = StorageConfig.newBuilder("/path/to/db")
    .withDurableWrites(true)       // fsync on every write
    .withMemoryBufferSize(64)      // 64MB write buffer
    .withMaxMemoryBuffers(3)       // Keep 3 buffers
    .withBackgroundThreads(4)      // Compaction threads
    .build();

QueueMetrics metrics = queue.getMetrics();

System.out.println("Total jobs: " + metrics.getTotalJobs());
System.out.println("Queued: " + metrics.getQueuedJobs());
System.out.println("Leased: " + metrics.getLeasedJobs());
System.out.println("Completed: " + metrics.getSuccessfulJobs());
System.out.println("Failed: " + metrics.getFailedJobs());