we have the following route starting with a SEDA queue:
RouteDefinition sedaMediaRoute = from("seda:test?concurrentConsumers=2
We are stopping the route in this way:
camelContext.stopRoute(MEDIA_PROCESSOR_QUEUE_ROUTE_ID, 1, TimeUnit.SECONDS);
When the queue stops, the third librery used in the testProcessor
throws an *ClosedByInterruptException *because it reveals the thread
interruption during an I/O operation.
Now we are wondering if it were possible to stop the SEDA queue,
stopping the consumers from picking up new messages, without
interrupting the execution of the threads
that are still processing exchanges from testProcessor onwards, in
order to not throw the reported exception.
Thank you very much.
Vincenzo De Vivo 's gravatar image asked Feb 17 2017 at 07:06 in Camel-Users by Vincenzo De Vivo

1 Answers

Dont use so little timeout with only 1 second, set it as a higher value
Claus Ibsen
http://davsclaus.com @davsclaus
Camel in Action 2: https://www.manning.com/ibsen2
Claus Ibsen 's gravatar image answered Feb 17 2017 at 07:34 by Claus Ibsen

Related Discussions