Весна Интеграция: Маршрутизация сообщений в процентах полученных сообщений

Question

Как реализовать требование разделить существующий канал запроса на основе Spring Integration для маршрутизации фиксированного процента сообщений на канал Rabbit MQ? Маршрутизация НЕ должна основываться на полезной нагрузке или заголовке. Есть ли в ящике способ указать, что один из них может идти по одному каналу и оставаться на другом? Благодаря

Answer 1

Вот один из способов ...

<bean id="counter" class="java.util.concurrent.atomic.AtomicInteger" /> 

<int:router id="percentageRouter" input-channel="routePercentage" 
     expression="@counter.getAndIncrement() % 10 == 0"> 
    <int:mapping value="true" channel="tenpercent" /> 
    <int:mapping value="false" channel="ninetypercent" /> 
</int:router>