[
https://issues.apache.org/jira/browse/CAMEL-22111?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17954592#comment-17954592
]
Aurélien Pupier commented on CAMEL-22111:
-----------------------------------------
it is a matter of timing. If I put a Thread.sleep at the beinning of the test
method it is working locally.
There is already a specific waitStrategy fo the container to be ready. Maybe
there could be a way to ensure that everything is ready correctly with a more
rpecise/different pattern
org.apache.camel.test.infra.elasticsearch.services.ElasticSearchLocalContainerInfraService.initContainer(String)
> Fix test ElasticsearchRestClientComponentIT.testProducer
> --------------------------------------------------------
>
> Key: CAMEL-22111
> URL: https://issues.apache.org/jira/browse/CAMEL-22111
> Project: Camel
> Issue Type: Test
> Components: camel-elasticsearch-rest, tests
> Affects Versions: 4.12.0
> Reporter: Aurélien Pupier
> Priority: Major
> Fix For: 4.13.0
>
>
> {noformat}
> java.util.concurrent.ExecutionException:
> org.apache.camel.CamelExecutionException: Exception occurred during execution
> on the exchange: Exchange[A7D41C29C06B089-0000000000000000]
> at
> java.base/java.util.concurrent.CompletableFuture.reportGet(CompletableFuture.java:396)
> at
> java.base/java.util.concurrent.CompletableFuture.get(CompletableFuture.java:2073)
> at
> org.apache.camel.component.elasticsearch.rest.client.integration.ElasticsearchRestClientComponentIT.testProducer(ElasticsearchRestClientComponentIT.java:86)
> at java.base/java.lang.reflect.Method.invoke(Method.java:569)
> at java.base/java.util.ArrayList.forEach(ArrayList.java:1511)
> at java.base/java.util.ArrayList.forEach(ArrayList.java:1511)
> Caused by: org.apache.camel.CamelExecutionException: Exception occurred
> during execution on the exchange: Exchange[A7D41C29C06B089-0000000000000000]
> at
> org.apache.camel.CamelExecutionException.wrapCamelExecutionException(CamelExecutionException.java:45)
> at
> org.apache.camel.support.ExchangeHelper.extractResultBody(ExchangeHelper.java:701)
> at
> org.apache.camel.impl.engine.DefaultProducerTemplate.extractResultBody(DefaultProducerTemplate.java:594)
> at
> org.apache.camel.impl.engine.DefaultProducerTemplate.lambda$asyncRequestBody$2(DefaultProducerTemplate.java:727)
> at
> java.base/java.util.concurrent.CompletableFuture$UniApply.tryFire(CompletableFuture.java:646)
> at
> java.base/java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:510)
> at
> java.base/java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:2147)
> at
> org.apache.camel.support.cache.DefaultProducerCache.lambda$doAsyncSendExchange$3(DefaultProducerCache.java:226)
> at
> org.apache.camel.support.cache.DefaultProducerCache.lambda$doInAsyncProducer$4(DefaultProducerCache.java:292)
> at org.apache.camel.AsyncCallback.run(AsyncCallback.java:44)
> at
> org.apache.camel.impl.engine.DefaultReactiveExecutor$Worker.doRun(DefaultReactiveExecutor.java:199)
> at
> org.apache.camel.impl.engine.DefaultReactiveExecutor$Worker.executeReactiveWork(DefaultReactiveExecutor.java:189)
> at
> org.apache.camel.impl.engine.DefaultReactiveExecutor$Worker.tryExecuteReactiveWork(DefaultReactiveExecutor.java:166)
> at
> org.apache.camel.impl.engine.DefaultReactiveExecutor$Worker.schedule(DefaultReactiveExecutor.java:148)
> at
> org.apache.camel.impl.engine.DefaultReactiveExecutor.schedule(DefaultReactiveExecutor.java:54)
> at
> org.apache.camel.processor.errorhandler.RedeliveryErrorHandler$SimpleTask.handlePreviousFailure(RedeliveryErrorHandler.java:450)
> at
> org.apache.camel.processor.errorhandler.RedeliveryErrorHandler$SimpleTask.run(RedeliveryErrorHandler.java:413)
> at
> org.apache.camel.processor.errorhandler.RedeliveryErrorHandler$SimpleTask.done(RedeliveryErrorHandler.java:392)
> at
> org.apache.camel.component.elasticsearch.rest.client.ElasticsearchRestClientProducer$1.onFailure(ElasticsearchRestClientProducer.java:197)
> at
> org.elasticsearch.client.RestClient$FailureTrackingResponseListener.onDefinitiveFailure(RestClient.java:688)
> at org.elasticsearch.client.RestClient$1.completed(RestClient.java:413)
> at org.elasticsearch.client.RestClient$1.completed(RestClient.java:397)
> at
> org.apache.http.concurrent.BasicFuture.completed(BasicFuture.java:122)
> at
> org.apache.http.impl.nio.client.DefaultClientExchangeHandlerImpl.responseCompleted(DefaultClientExchangeHandlerImpl.java:182)
> at
> org.apache.http.nio.protocol.HttpAsyncRequestExecutor.processResponse(HttpAsyncRequestExecutor.java:448)
> at
> org.apache.http.nio.protocol.HttpAsyncRequestExecutor.inputReady(HttpAsyncRequestExecutor.java:338)
> at
> org.apache.http.impl.nio.DefaultNHttpClientConnection.consumeInput(DefaultNHttpClientConnection.java:265)
> at
> org.apache.http.impl.nio.client.InternalIODispatch.onInputReady(InternalIODispatch.java:87)
> at
> org.apache.http.impl.nio.client.InternalIODispatch.onInputReady(InternalIODispatch.java:40)
> at
> org.apache.http.impl.nio.reactor.AbstractIODispatch.inputReady(AbstractIODispatch.java:121)
> at
> org.apache.http.impl.nio.reactor.BaseIOReactor.readable(BaseIOReactor.java:162)
> at
> org.apache.http.impl.nio.reactor.AbstractIOReactor.processEvent(AbstractIOReactor.java:337)
> at
> org.apache.http.impl.nio.reactor.AbstractIOReactor.processEvents(AbstractIOReactor.java:315)
> at
> org.apache.http.impl.nio.reactor.AbstractIOReactor.execute(AbstractIOReactor.java:276)
> at
> org.apache.http.impl.nio.reactor.BaseIOReactor.execute(BaseIOReactor.java:104)
> at
> org.apache.http.impl.nio.reactor.AbstractMultiworkerIOReactor$Worker.run(AbstractMultiworkerIOReactor.java:591)
> at java.base/java.lang.Thread.run(Thread.java:840)
> Caused by: org.elasticsearch.client.ResponseException: method [PUT], host
> [https://localhost:47378], URI [/my_index], status line [HTTP/1.1 401
> Unauthorized]
> {"error":{"root_cause":[{"type":"security_exception","reason":"unable to
> authenticate user [elastic] for REST request
> [/my_index]","header":{"WWW-Authenticate":["Bearer
> realm=\"security\"","ApiKey","Basic realm=\"security\",
> charset=\"UTF-8\""]}}],"type":"security_exception","reason":"unable to
> authenticate user [elastic] for REST request
> [/my_index]","header":{"WWW-Authenticate":["Bearer
> realm=\"security\"","ApiKey","Basic realm=\"security\",
> charset=\"UTF-8\""]}},"status":401}
> at
> org.elasticsearch.client.RestClient.convertResponse(RestClient.java:351)
> at org.elasticsearch.client.RestClient.access$1900(RestClient.java:109)
> at org.elasticsearch.client.RestClient$1.completed(RestClient.java:401)
> ... 16 more
> {noformat}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
