关于编年史队列中的子主题
Regarding sub-topics in chronicle queue
我正在寻找将消息写入单个队列的方法。我想使用子主题功能,以便零售商可以选择阅读一个主题下的所有子主题,或者选择特定的子主题来阅读。
文档中提到在主主题下的目录中支持子主题,那么为了从子主题中读取,我们是否只需创建一个新队列并将其指向子主题路径?
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
Chronicle-Queue 中没有真正的层次结构概念;文件系统目录和队列之间存在一对一的映射。
如果您希望过滤某些记录,则需要在从队列中读取记录时执行此操作。将由您的应用程序决定如何检测应过滤的消息。
您引用的文档似乎是从 Chronicle-Engine 中存在的概念复制而来的。
我正在寻找将消息写入单个队列的方法。我想使用子主题功能,以便零售商可以选择阅读一个主题下的所有子主题,或者选择特定的子主题来阅读。
文档中提到在主主题下的目录中支持子主题,那么为了从子主题中读取,我们是否只需创建一个新队列并将其指向子主题路径?
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
Chronicle-Queue 中没有真正的层次结构概念;文件系统目录和队列之间存在一对一的映射。
如果您希望过滤某些记录,则需要在从队列中读取记录时执行此操作。将由您的应用程序决定如何检测应过滤的消息。
您引用的文档似乎是从 Chronicle-Engine 中存在的概念复制而来的。