chronicle-queue - ChronicleQueue - 如何从tailer 读取自定义对象

Question

我对 ChronicleQueue 非常陌生，我无法找到一个直接的示例来说明如何从tailer 读回我的自定义对象。

public class MyData extends AbstractMarshallable

我的课程包含一些字符串和数字，我可以使用 appender 写入队列，但是没有直接的 api 可以调用。如何从 tailer.readDocument api 获取 MyData 对象？

Answer 1

试试下面的代码：

final DocumentContext context = queue.createTailer().readingDocument();
final MyData container = new MyData();
if (context.isPresent()) {
    context.wire().getValueIn().marshallable(container);
}

这假定附加是以下列方式执行的：

try (DocumentContext ctx = appender.writingDocument()) {
    ctx.wire().getValueOut().marshallable(myData);
}