227.10. 启用持久性尾部跟踪
要启用这个功能,请在端点 URI 上至少设置以下选项:
-
persistentTailTracking
选项为true
-
persistentId
选项用于这个使用者的唯一标识符,以便可以在很多消费者之间重复使用相同的集合
另外,您可以将 tailTrackDb
、tailTrackCollection
和 tailTrackField
选项设置为自定义存储运行时信息的位置。有关每个选项的描述,请参阅本页顶部的端点选项表。
例如,以下路由会使用来自 "flights.cancellations" capped 集合,使用 "departureTime" 作为增大字段,默认的 regeneration 光标延迟为 1000ms,打开持久的 tail 跟踪,并在 "flights.camelTailTailTracking" 的 "cancellationsTracker" id 下保留。 在 "lastTrackingValue" 字段中存储最后一个处理的值(camelTailTracking
和 lastTrackingValue
为 defaults)。
from("mongodb:myDb?database=flights&collection=cancellations&tailTrackIncreasingField=departureTime&persistentTailTracking=true" + "&persistentId=cancellationsTracker") .id("tailableCursorConsumer2") .autoStartup(false) .to("mock:test");
from("mongodb:myDb?database=flights&collection=cancellations&tailTrackIncreasingField=departureTime&persistentTailTracking=true" +
"&persistentId=cancellationsTracker")
.id("tailableCursorConsumer2")
.autoStartup(false)
.to("mock:test");
以下是与上面的另一个示例相同,但其中持久性 tail 跟踪运行时信息将存储在 "trackers.camelTrackers" 字段中的 "lastProcessedDepartureTime" 字段中:
from("mongodb:myDb?database=flights&collection=cancellations&tailTrackIncreasingField=departureTime&persistentTailTracking=true" + "&persistentId=cancellationsTracker&tailTrackDb=trackers&tailTrackCollection=camelTrackers" + "&tailTrackField=lastProcessedDepartureTime") .id("tailableCursorConsumer3") .autoStartup(false) .to("mock:test");
from("mongodb:myDb?database=flights&collection=cancellations&tailTrackIncreasingField=departureTime&persistentTailTracking=true" +
"&persistentId=cancellationsTracker&tailTrackDb=trackers&tailTrackCollection=camelTrackers" +
"&tailTrackField=lastProcessedDepartureTime")
.id("tailableCursorConsumer3")
.autoStartup(false)
.to("mock:test");