Spring-Integration and Threads. TaskExecutor

<integr:channel id="testChannel">
    <integr:queue capacity="100"/>
</integr:channel>
<task:scheduled-tasks>
    <task:scheduled ref="tstBean" method="execute" cron="1 * * * * *"/>
</task:scheduled-tasks>
<integr:service-activator input-channel="testChannel" ref="readTst" method="receive">
  <integr:poller task-executor="taskExecutor" receive-timeout="3000" fixed-delay="1" time-unit="SECONDS" max-messages-per-poll="10"/>
</integr:service-activator>
<task:executor id="taskExecutor" pool-size="10" queue-capacity="1"/>
<bean id="tstBean" class="WriteTstSource"/>
<bean id="readTst" class="ReadTstSource"/>

Заполняю очередь 10-ю сообщениями, начинаю их считывать 10-ю потоками. В идеале эти 10 сообщений я и должен получить обратно, но вместо этого получаю на выходе произвольное число. Почему так происходит, где ошибка, не могу понять, на каком этапе получения теряю сообщения и как это исправить. Помогите разобраться. Спасибо.