Croway opened a new pull request, #21303:
URL: https://github.com/apache/camel/pull/21303
Fixes camel-mllp under heavy load, or high thread contention (like in
camel-quarkus tests).
Camel-Quarkus mllp integration tests were failing due to producer timeouts
in a scenario where camel is used both as consumer and producer.
the issue was that
```
getEndpoint().getCamelContext().getExecutorServiceManager()
.newThreadPool(this, "MllpConsumer",
1, getConfiguration().getMaxConcurrentConsumers());
```
uses a 1k elements queue by default, and with high thread contention or high
load, the consumer does not start processing the messages fast enough,
therefore the producer fail due to acknowledge timeout.
The important fix is `consumerProfile.setMaxQueueSize(0);` this way a
SynchrnousQueue is used, like it was before, and new threads are used to
consume the message.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
