Michwo commented on PR #22674: URL: https://github.com/apache/camel/pull/22674#issuecomment-4780072303
I've finally found some time to work on that again - I've reimplemented this like @orpiske and @Croway have suggested, as an resume strategy eip. I used the camel-kafka's implementation as a template for this. Changes included: - MongoDB change streams now work with the Resume API/EIP. - Added MongoDB resume strategy + configuration builder support. - Resume token (offset) key is now based on route id and collection (with endpoint fallback). This was a decision based on the way WatchStreamConsumer is configured - more consumers per collection possible watching different changes based on BSON filter - therefore each consumer endpoint should be able to ingest the changes separately. - Resume tokens are stored as JSON strings - resumable completion updates the strategy from exchange offset Startup token priority: resume strategy token first, then endpoint/repository Test for the added code are included (value/integration). The documentation is also updated to reflect the changes (camel-mongodb and Resume Strategies). -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
