fteychene

public class Batcher {
    
    static class Flusher implements Runnable {
        private ConcurrentLinkedQueue<Events.Event> queu = new ConcurrentLinkedQueue<>();

        @Override
        public void run() {
            // Flush with defined interval or with special rules
        }
        

fteychene

package fte.tests.chronicle;

import com.cognitect.transit.Reader;
import com.cognitect.transit.TransitFactory;
import com.cognitect.transit.Writer;
import com.fasterxml.jackson.databind.ObjectMapper;
import com.fasterxml.jackson.datatype.guava.GuavaModule;
import com.fasterxml.jackson.datatype.jdk8.Jdk8Module;
import net.openhft.chronicle.Chronicle;
import net.openhft.chronicle.ChronicleQueueBuilder;