Hi You can try adding retryWhile to your onException and check if the route status if its stopping, and then return false to break the retry sooner.
On Tue, May 7, 2024 at 4:11 PM Speckels, Bert <bert.speck...@btc-ag.com> wrote: > I have created a simple example project which demonstrates the > different behaviouts of "camel rabbitmq" and "camel spring rabbitmq": > > https://github.com/Skrrytch/camel-and-rabbitmq-issue > This demonstrates both components so you can see the different behaviour. > See readme.md for details like code description, how to run and reproduce. > > ... and the corresponding Stack Overflow entry: > > > https://stackoverflow.com/questions/78443006/impossible-to-stop-a-route-with-inflight-messages-which-are-in-redelivery-when > > Maybe someone can help because we need a way to interrupt a redelivery > by stopping the route for maintenance as well as stop, remove the message > from queue and restart. > > With kind regards > Bert. > ________________________________ > Von: Speckels, Bert <bert.speck...@btc-ag.com> > Gesendet: Donnerstag, 18. April 2024 18:25 > An: users@camel.apache.org <users@camel.apache.org> > Betreff: Stopping a route while in retry (how to interrupt the retry?) ... > worked great before migration to "camel spring rabbitmq" > > Hello everyone. > > I hope to get some useful information about our current problem. I'll > try to keep it brief and still provide enough information. Ask if any > more information is required. > > We migrated our camel routes which receive messages from RabbitMQ to > "camel spring rabbitmq" (since "camel rabbitmq" has been removed in > camel 4). > > First of all: > <spring-boot.version>3.2.4</spring-boot.version> > <camel.version>4.4.0</camel.version> > <java.version>17</java.version> > (First we also tried with camel 3.22.1 and spring boot 2.7.18) > > Everything worked great after the migration, except for one special case: > > For maintenance we sometimes need to STOP the routes (e.g. via JMX): The > rabbitmq consumers should be stopped and inflight messages remain in > RabbitMQ, ready to be consumed again after maintenance. > > That worked like a charm with "camel rabbitmq component": Even > when there was a message in (Camel) RETRY for some minutes, that route has > been stopped > after the configured timeout of 5 seconds, the retry (Thread.sleep) has > been > interrupted and the message in RabbitMQ was ready to be consumed > again. > > But with "camel spring rabbitmq" the message in retry is no longer > interrupted: It continues to run despite the rabbit consumer being and the > consuming route has been stopped > (we can see that in Hawt.io) > > I attached two log outputs: The first one with "camel rabbitmq" (where you > can > see the interruption of Thread.sleep) and another one with "camel > spring rabbitmq": As you can see, camel is waiting for the inflight > message to finish but then forces the route to stop ... but the retry > thread is still running and tries to redeliver the message (we can see > the delivery failures while the consumer and route is stopped) > > Thanks for reading all this. I hope I made my point clear?! > > With kind regards > Bert > -- Claus Ibsen ----------------- @davsclaus Camel in Action 2: https://www.manning.com/ibsen2
