【发布时间】:2015-06-17 13:58:29
【问题描述】:
如何实现拆分现有基于 Spring Integration 的请求通道以将固定百分比的消息路由到基于 Rabbit MQ 的通道的要求?路由不应基于有效负载或标头。是否有一种开箱即用的方式来指定其中一个可能应该在一个频道上进行并保留在另一个频道上?谢谢
【问题讨论】:
如何实现拆分现有基于 Spring Integration 的请求通道以将固定百分比的消息路由到基于 Rabbit MQ 的通道的要求?路由不应基于有效负载或标头。是否有一种开箱即用的方式来指定其中一个可能应该在一个频道上进行并保留在另一个频道上?谢谢
【问题讨论】:
这是一种方法...
<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>
【讨论】: