如何在spring集成中使用聚合器对事件进行分组/批处理

<int:channel id="inputChannel" />
<int:channel id="outputChannel" />

<int:aggregator input-channel="inputChannel"
                output-channel="outputChannel"
                release-strategy-expression="size() == 10"
                release-strategy-method="checkReleaseStrategy"
                correlation-strategy-expression="payload.groupId"
                correlation-strategy-method="determineCorrelationKey"
                send-partial-result-on-expiry="true"
                expire-groups-upon-completion="true"
                expire-groups-upon-timeout="true"
                group-timeout="5000" />

<int:service-activator input-channel="outputChannel"
                       ref="eventHandler"
                       method="handleEvent" />

<int:gateway id="eventGateway"
             service-interface="com.example.EventGateway"
             default-request-channel="inputChannel" />