I've been trying to reproduce the behaviour shown at this github page:
https://github.com/olegz/s12gx.2011/...ion/aggregator

However, I see only one group released when debugging and in the log.

Code:
<channel id="inboundBatchingChannel" />

    <aggregator input-channel="inboundBatchingChannel"
                output-channel="batchChannel"
                expire-groups-upon-completion="false"
                send-partial-result-on-expiry="true"
                message-store="batchMessageStore"
                release-strategy-expression="size() == 10"
            />

    <channel id="batchChannel">
        <interceptors>
            <wire-tap channel="aggregatedBatchLogger"/>
        </interceptors>
    </channel>

    <logging-channel-adapter id="aggregatedBatchLogger"
                             log-full-message="true"
                             level="DEBUG" logger-name="AGGREGATED-BATCHES-LOGGER"  />
    
    <beans:bean id="reaper" class="org.springframework.integration.store.MessageGroupStoreReaper">
        <beans:property name="messageGroupStore" ref="messageStore"/>
        <beans:property name="timeout" value="5000"/>
    </beans:bean>

    <task:scheduled-tasks scheduler="scheduler">
        <task:scheduled ref="reaper" method="run" fixed-rate="100"/>
    </task:scheduled-tasks>

    <task:scheduler id="scheduler"/>
I have 25 items being written to the inbound channel. I'm hoping for 3 groups to be created by the aggregator, but I only see one.