當達到限制限制時，如何將駱駝等待消息發送到目錄？

Question

我有這種情況，我想在一個小時的時間範圍內接受前100條消息，並通過名爲handleMessage的bean處理這些消息。然後，超過100個限制的任何消息，我想簡單地將它們放入一個目錄（或傳遞給一個單獨的bean），並且永遠不會通過主處理bean發送它們。目前，如果接收到101條消息，則在1小時的時間限制結束後，101st消息處於阻止狀態並由「handleMessage」處理。

<route> 
    <from uri="file://inputdir/"/> 
    <!-- throttle 100 messages per hour --> 
    <throttle timePeriodMillis="3600000"> 
     <constant>100</constant> 
     <bean name="handleMessage" method="process"/> 
    </throttle> 
</route> 

Answer 1

調速器不支持這一點，它會一直阻止消息並在時隙可用時執行它們。

你需要編寫你自己的定製eip/bean /處理器來完成你想要的任務。