如何在spring中使用change stream监听多个集合

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-data-mongodb</artifactId>
</dependency>

@Component
public class MyChangeStreamListener {

    @EventListener(condition = "#event.operationType.name() == 'INSERT'")
    public void handleInsertEvent(ChangeStreamEvent<Document> event) {
        // 处理插入事件
        Document document = event.getBody();
        // ...
    }

    @EventListener(condition = "#event.operationType.name() == 'UPDATE'")
    public void handleUpdateEvent(ChangeStreamEvent<Document> event) {
        // 处理更新事件
        Document document = event.getBody();
        // ...
    }

    // 其他操作类型的事件处理方法
}

@Configuration
public class ChangeStreamConfig {

    @Autowired
    private MongoTemplate mongoTemplate;

    @Bean
    public ChangeStreamRequest<Document> changeStreamRequest() {
        ChangeStreamRequest<Document> request = ChangeStreamRequest.builder()
                .collection("collection1", "collection2") // 要监听的集合
                .filter(newAggregation(match(Criteria.where("operationType").in("insert", "update")))) // 过滤条件
                .build();

        return request;
    }

    @Bean
    public ChangeStreamListener<Document> changeStreamListener() {
        return new ChangeStreamListener<Document>() {
            @Override
            public void onMessage(ChangeStreamDocument<Document> document) {
                // 处理Change Stream事件
                // ...
            }
        };
    }

    @Bean
    public ChangeStreamMessageListenerContainer<Document> changeStreamMessageListenerContainer() {
        return new ChangeStreamMessageListenerContainer<>(mongoTemplate, changeStreamRequest(), changeStreamListener());
    }
}

@SpringBootApplication
@EnableChangeStream
public class Application {

    public static void main(String[] args) {
        SpringApplication.run(Application.class, args);
    }
}