@@ -0,0 +1,1855 @@
+package net.openhft.chronicle.queue;%0A%0Aimport net.openhft.chronicle.core.OS;%0Aimport net.openhft.chronicle.core.io.IOTools;%0Aimport net.openhft.chronicle.core.time.SetTimeProvider;%0Aimport net.openhft.chronicle.queue.impl.single.SingleChronicleQueueBuilder;%0Aimport org.junit.Test;%0A%0Aimport static org.junit.Assert.assertEquals;%0A%0Apublic class AppenderListenerTest %7B%0A%0A    @Test%0A    public void appenderListenerTest() %7B%0A        String path = OS.getTarget() + %22/appenderListenerTest%22;%0A        StringBuilder results = new StringBuilder();%0A        try (ChronicleQueue q = SingleChronicleQueueBuilder.single(path)%0A                .testBlockSize()%0A                .appenderListener((wire, index) -%3E %7B%0A                    long offset = ((index %3E%3E%3E 32) %3C%3C 40) %7C wire.bytes().readPosition();%0A                    String event = wire.readEvent(String.class);%0A                    String text = wire.getValueIn().text();%0A                    results.append(event)%0A                            .append(%22 %22).append(text)%0A                            .append(%22, addr:%22).append(Long.toHexString(offset))%0A                            .append(%22, index: %22).append(Long.toHexString(index)).append(%22%5Cn%22);%0A                %7D)%0A                .timeProvider(new SetTimeProvider(%222021/11/29T13:53:59%22).advanceMillis(1000))%0A                .build();%0A             ExcerptAppender appender = q.acquireAppender()) %7B%0A            final HelloWorld writer = appender.methodWriter(HelloWorld.class);%0A            writer.hello(%22G'Day%22);%0A            writer.hello(%22Bye-now%22);%0A        %7D%0A        IOTools.deleteDirWithFiles(path);%0A        assertEquals(%22%22 +%0A                %22hello G'Day, addr:4a10000001010c, index: 4a1000000000%5Cn%22 +%0A                %22hello Bye-now, addr:4a100000010120, index: 4a1000000001%5Cn%22, results.toString());%0A    %7D%0A%0A    public interface HelloWorld %7B%0A        void hello(String s);%0A    %7D%0A%7D

Add support for listening to messages as they are appended #954