mongodb - 在 spring 集成中借助 mongo 入站适配器对数据进行分页

Question

我正在使用 mongo 入站适配器从 mongo 检索数据。目前我正在使用以下配置。

<int-mongo:inbound-channel-adapter
        id="mongoInboundAdapter" collection-name="updates_IPMS_PRICING"
        mongo-template="mongoTemplatePublisher" channel="ipmsPricingUpdateChannelSplitter"
        query="{'flagged' : false}" entity-class="com.snapdeal.coms.publisher.bean.PublisherVendorProductUpdate">
        <poller max-messages-per-poll="2" fixed-rate="10000"></poller>
    </int-mongo:inbound-channel-adapter>

我的数据库中有大约 20 条符合上述查询条件的记录，但由于我给出的 max-messages-per-poll 值为 2，所以我希望每次投票最多能获得 2 条记录。但我得到了所有符合上述查询条件的记录。不确定我做错了什么。

Answer 1

实际上我建议提出一个新特性 JIRA ticket对于那个 query-expression 允许指定 org.springframework.data.mongodb.core.query.Query 构建器，它有 skip()和 limit() 选项，您的问题可以从那里得到解决，例如:

<int-mongo:inbound-channel-adapter
    query-expression="new BasicQuery('{\'flagged\' : false}').limit(2)"/>