Skip to content

GH-2788: Add MongoDbChangeStreamMessageProducer #3240

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom
Closed
wants to merge 3 commits into from
Closed

GH-2788: Add MongoDbChangeStreamMessageProducer #3240

wants to merge 3 commits into from

Conversation

artembilan
Copy link
Member

Fixes #2788

  • Introduce a MessageProducerSupport.subscribeToPublisher(Publisher<Message<?>>)
    for components which produces Flux for data from their source
  • Such a component is auto-stopped when subscription to that Publisher is canceled
  • Implement a MongoDbChangeStreamMessageProducer based on the reactive support for
    in Spring Data MongoDb
  • Implement a Java DSL for MongoDbChangeStreamMessageProducer
  • Disable a test for change stream since it requires server of version 4.x started with 'replSet' option
  • Add MongoHeaders for change stream events

@artembilan
spring-projectsGH-2788: Add MongoDbChangeStreamMessageProducer
ce393aa 
Fixes spring-projects#2788

* Introduce a `MessageProducerSupport.subscribeToPublisher(Publisher<Message<?>>)`
for components which produces `Flux` for data from their source
* Such a component is auto-stopped when subscription to that `Publisher` is canceled
* Implement a `MongoDbChangeStreamMessageProducer` based on the reactive support for
in Spring Data MongoDb
* Implement a Java DSL for `MongoDbChangeStreamMessageProducer`
* Disable a test for change stream since it requires server of version 4.x started with 'replSet' option
* Add `MongoHeaders` for change stream events
@artembilan
Copy link
Member Author

TODO: Docs.

Probably some rework after consultation with Reactor team...

This was referenced Apr 5, 2020
Closed
Closed
@artembilan
* Change MessageProducerSupport to use a `takeWhile((message) -> is…
a060f14 
…Running())`

instead of storing a `subscription` from a callback
* Document new features
@artembilan
Copy link
Member Author

Pushed the fix for auto-completion of producing via .takeWhile((message) -> isRunning()) after consulting with Reactor team.
Documented new features.

@artembilan artembilan requested a review from garyrussell April 6, 2020 17:54
@artembilan artembilan mentioned this pull request Apr 7, 2020
Closed
@garyrussell
Copy link
Contributor

Rebased and merged as d8c378b with minor doc polishing.

@garyrussell garyrussell closed this Apr 7, 2020
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Reviewers

@garyrussell garyrussell Awaiting requested review from garyrussell

Assignees
No one assigned
Labels
None yet
Projects
None yet
Milestone
No milestone
Development

Successfully merging this pull request may close these issues.

Feature request: mongo change stream
2 participants
@artembilan @garyrussell