How to listen to multiple collections using change stream in spring

user_903137 0
Viewed 1480

I wants to collect data from to collection_one, collection_two, collection_three etc, how do I do that ?

       ChangeStreamRequest request = ChangeStreamRequest.builder().collation(Collation.of("collection_one"))
            .filter(Aggregation.newAggregation(match(where("operationType").exists(true))))
            .publishTo(krakenDtoMessageListener)
            .build();
    container.register(request, CollectionOne.class);

Should I create multiple changeStreamRequest or one should be fine ?

spring-boot mongodb java
2 Answers

While configuring change stream, you can specify filter on collection.

Check below java code,

List<Bson> pipeline = singletonList(Aggregates.match(
    Filters.in("ns.coll", asList("coll1", "coll2", "coll3"))
));

MongoCursor<ChangeStreamDocument<Document>> cursor = db.watch(pipeline).fullDocument(FullDocument.UPDATE_LOOKUP).iterator();

You can write similar pipeline using spring framework.

user_30795200

Cannot watch for multiple collections. According to mongoDB documentation, there are 3 options. watch a specific collection, watch a database or watch the deployment (all the databases) refer mongo documentation for more details

user_30075810
Related