[jira] [Updated] (CAMEL-18816) camel-ahc component crashes when a traffic starts too early

["Claus Ibsen (Jira)" <ji...@apache.org>]

     [ https://issues.apache.org/jira/browse/CAMEL-18816?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Claus Ibsen updated CAMEL-18816:
--------------------------------
    Priority: Minor  (was: Major)

> camel-ahc component crashes when a traffic starts too early
> -----------------------------------------------------------
>
>                 Key: CAMEL-18816
>                 URL: https://issues.apache.org/jira/browse/CAMEL-18816
>             Project: Camel
>          Issue Type: Bug
>          Components: camel-ahc
>    Affects Versions: 3.18.4
>            Reporter: Krzysztof Mackowiak
>            Priority: Minor
>         Attachments: camel-ahc-bug.patch
>
>
> Unfortunately it looks that when traffic to camel-ahc component starts to early it crashes with an exception:
> {code:java}
> org.apache.camel.FailedToCreateProducerException: Failed to create Producer for endpoint: ahc://http://localhost:59729/foo.
> Reason: java.lang.IllegalArgumentException: AsyncHttpClient must be specified on: ahc://http://localhost:59729/foo
>    at org.apache.camel.support.cache.DefaultProducerCache.acquireProducer(DefaultProducerCache.java:164)
>    at org.apache.camel.processor.RecipientListProcessor.doCreateProcessorExchangePairs(RecipientListProcessor.java:270)
>    at org.apache.camel.processor.RecipientListProcessor.createProcessorExchangePairs(RecipientListProcessor.java:246)
>    at org.apache.camel.processor.MulticastProcessor.process(MulticastProcessor.java:295)
>    at org.apache.camel.processor.RecipientList.process(RecipientList.java:175)
>    at org.apache.camel.processor.Pipeline$PipelineTask.run(Pipeline.java:106)
>    at org.apache.camel.impl.engine.DefaultReactiveExecutor$Worker.schedule(DefaultReactiveExecutor.java:189)
>    at org.apache.camel.impl.engine.DefaultReactiveExecutor.scheduleMain(DefaultReactiveExecutor.java:61)
>    at org.apache.camel.processor.Pipeline.process(Pipeline.java:182)
>    at org.apache.camel.impl.engine.CamelInternalProcessor.process(CamelInternalProcessor.java:399)
>    at org.apache.camel.component.timer.TimerConsumer.sendTimerExchange(TimerConsumer.java:210)
>    at org.apache.camel.component.timer.TimerConsumer$2.run(TimerConsumer.java:118)
>    at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)
>    at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)
>    at java.base/java.lang.Thread.run(Thread.java:829)
> Caused by: java.lang.IllegalArgumentException: AsyncHttpClient must be specified on: ahc://http://localhost:59729/foo
>    at org.apache.camel.util.ObjectHelper.notNull(ObjectHelper.java:176)
>    at org.apache.camel.component.ahc.AhcEndpoint.createProducer(AhcEndpoint.java:94)
>    at org.apache.camel.support.DefaultEndpoint.createAsyncProducer(DefaultEndpoint.java:200)
>    at org.apache.camel.support.cache.ServicePool$SinglePool.acquire(ServicePool.java:237)
>    at org.apache.camel.support.cache.ServicePool$SinglePool.acquire(ServicePool.java:216)
>    at org.apache.camel.support.cache.ServicePool.acquire(ServicePool.java:112)
>    at org.apache.camel.support.cache.ProducerServicePool.acquire(ProducerServicePool.java:28)
>    at org.apache.camel.support.cache.DefaultProducerCache.acquireProducer(DefaultProducerCache.java:149)
>    ... 14 common frames omitted
> {code}
> It causes that all traffic to camel-ahc endpoint is failing. It happens in my application for routes that take messages from JMS queue and sent it to HTTP (using camel-ahc component).
> Here is a test that reproduces a problem:
> {code:java}
> public class AhcRecipientListTest extends BaseAhcTest {
>     @Test
>     public void testRecipientListCalledBeforeComponentStarted() throws Exception {
>         getMockEndpoint("mock:result").expectedBodiesReceived("Hello");
>         assertMockEndpointsSatisfied();
>     }
>     @Override
>     protected RouteBuilder createRouteBuilder() throws Exception {
>         return new RouteBuilder() {
>             @Override
>             public void configure() throws Exception {
>                 from("timer://foo?delay=-1&?repeatCount=1")
>                     .recipientList(constant(getAhcEndpointUri()))
>                     .to("mock:result");
>                 from(getTestServerEndpointUri())
>                     .transform(constant("Hello"));
>             }
>         };
>     }
> } {code}
> I've prepared a patch with another 2 tests and a possible bugfix. The bugfix is based on a solution from HttpEnpoint/HttpProducer.
> The bug was discovered in version 3.18.4, but it looks that it was present for a long time.



--
This message was sent by Atlassian Jira
(v8.20.10#820010)