Lime - fulmicotone/com.fulmicotone.util.concurrent.tree GitHub Wiki
Lime is a runnable that contains the generic logic to get an item from a BlockingQueue and consume it through an Act function. Merging Lime and Act and Submitting it into Tree, gives us some advantages:
- On error Auto recommit with unconsumed items preservation.
- Forced stop in case of item's flow slower than indicated amount of millis
- Connection to others Runnable's queues
- A single items stream through commons Monitor tree Runnable
- Asynchronous consumption