0

我正在寻找将消息写入单个队列。我想使用子主题功能，以便裁缝可以选择阅读一个主题下的所有子主题，或者选择要阅读的特定子主题。

文档中提到在主主题下的目录中支持子主题，所以为了从子主题中读取，我们是否只需创建一个新队列并将其指向子主题路径？

    SingleChronicleQueue queue = SingleChronicleQueueBuilder.binary("Topic").build();
    SingleChronicleQueue queue2 = SingleChronicleQueueBuilder.binary("Topic/SubTopic").build();

    ExcerptAppender appender = queue.acquireAppender();
    ExcerptAppender appender2 = queue2.acquireAppender();

    appender.writeText("aaa");
    appender2.writeText("bbb");

这只会输出 aaa，但我希望它输出 aaa 和 bbb

4

1 回答 1

0

Chronicle-Queue 中没有真正的层次概念；文件系统目录和队列之间存在一对一的映射。

如果您希望过滤某些记录，则需要在从队列中读取记录时执行此操作。由您的应用程序决定如何检测应过滤的消息。

您引用的文档似乎是从Chronicle-Engine中存在的概念复制而来的。

于 2017-12-06T07:45:23.237 回答