45.11. 启用持久的尾部跟踪

要启用此功能，请在端点 URI 中至少设置以下选项：

另外，您可以将 tailTrackDb,tailTrackCollection 和 tailTrackField 选项设置为自定义存储运行时信息的位置。有关每个选项的描述，请参阅此页面顶部的端点选项表。

例如，以下路由将使用"departureTime"作为增加字段的"flights.cancellations"大写集合，默认的重新生成光标延迟为 1000ms，持久性尾部跟踪打开，并在"flights.camelTracking" ID 下保留。 将最后处理的值存储在"lastTrackingValue"字段下(camelTailTracking 和 lastTrackingValue 是默认值)。

from("mongodb:myDb?database=flights&collection=cancellations&tailTrackIncreasingField=departureTime&persistentTailTracking=true" +
     "&persistentId=cancellationsTracker")
    .id("tailableCursorConsumer2")
    .autoStartup(false)
    .to("mock:test");

以下是与上述示例相同，但持久性尾部跟踪运行时信息将存储在"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");

<route id="filterConsumer">
    <from uri="mongodb:myDb?consumerType=changeStreams&amp;database=flights&amp;collection=tickets&amp;streamFilter={ '$match':{'$or':[{'fullDocument.stringValue': 'specificValue'}]} }"/>
    <to uri="mock:test"/>
</route>

from("mongodb:myDb?consumerType=changeStreams&database=flights&collection=tickets&streamFilter={ '$match':{'$or':[{'fullDocument.stringValue': 'specificValue'}]} }")
    .to("mock:test");