Chronicle 队列事件侦听器
Chronicle queue events listener
1) 在 chronicle queue v4 most test patterns show some form of DocumentContext.isPresent()
busy state checking 中,当 ExcerptTailer
位于队列末尾并且 代码正在等待 新条目来自 ExcerptAppender
.
2) 异步 appender -> tailer
通知是否有内置的编年史队列机制,以便在收到通知事件后,给定 tailer
保证至少有一个条目由appender
、准备好读取?
3) 如果不是,推荐的模式是什么来实现这样的event listener
?请分享一个工作示例?
实现侦听器模式的推荐模式是使用 methodReader/methodWriter,它还可以在您阅读的地方处理时间戳。
我建议您从第 1 部分开始阅读这些 https://vanilla-java.github.io/tag/Microservices/。
对于 tailer,它知道有消息的唯一方法是 reading/polling 队列的末尾。如果 appender 和 tailer 在同一个进程中,您可以使用您选择的不同机制。
1) 在 chronicle queue v4 most test patterns show some form of DocumentContext.isPresent()
busy state checking 中,当 ExcerptTailer
位于队列末尾并且 代码正在等待 新条目来自 ExcerptAppender
.
2) 异步 appender -> tailer
通知是否有内置的编年史队列机制,以便在收到通知事件后,给定 tailer
保证至少有一个条目由appender
、准备好读取?
3) 如果不是,推荐的模式是什么来实现这样的event listener
?请分享一个工作示例?
实现侦听器模式的推荐模式是使用 methodReader/methodWriter,它还可以在您阅读的地方处理时间戳。
我建议您从第 1 部分开始阅读这些 https://vanilla-java.github.io/tag/Microservices/。
对于 tailer,它知道有消息的唯一方法是 reading/polling 队列的末尾。如果 appender 和 tailer 在同一个进程中,您可以使用您选择的不同机制。