У меня есть простой веб-сервис ws1, у которого просто есть setBody для "hello world", который выставляется netty.Я хочу вызвать этот веб-сервис асинхронно с помощью camel-ahc.
для этого у меня есть основной верблюжий контекст, который вызывает ws1 каждые 6 секунд, но после вызова ws1 в другом потоке, элемент управленияпрограммы не возвращается в основной поток контекста верблюда, и кажется, что компонент camel-ahc не работает, и через 60 секунд происходит исключение тайм-аута запроса.в моем pom я добавил: camel-ahc camel-реагирующий-потоки
<camelContext trace="true" id="mainCamelContext" xmlns="http://camel.apache.org/schema/blueprint" >
<route id="ahc-route-first-api">
<from uri="timer://webinar?period=6000"/>
<log message="this is body: ${body}"/>
<to uri="ahc:http://192.168.100.232:9999/ws1"/>
<log message="this is body after call: ${body}"/>
</route>
</camelContext>
при установке пакета в Fuse:
10: 35: 18.914 INFO [Camel (mainCamelContext)поток # 316 - таймер: // вебинар] это тело: 10: 35: 18.914 ИНФОРМАЦИЯ [Camel (mainCamelContext) поток # 316 - таймер: // вебинар] ID-localhost-localdomain-1552973873885-38-116 >>> (ahc-route-first-api) log [это тело: $ {body}] -> ahc: // http://192.168.100.232:9999/api?throwExceptionOnFailure=false <<< Шаблон: InOnly, заголовки: {breadcrumbId = ID-localhost-localdomain-1552973873885-38-116, firedTime = сб. 06 апреля 10:35:18 IRDT 2019}, BodyType: null, Body: [Body is null] 10: 35: 19.202 WARN [AsyncHttpClient-timer-87-1] Ошибка обработки обмена.Обмен [ID-локальный-LOCALDOMAIN-1552973873885-38-114].Вызывается: [java.util.concurrent.TimeoutException - Время ожидания запроса до 192.168.100.232/192.168.100.232:9999 после 60000 мс] java.util.concurrent.TimeoutException: Время ожидания запроса до 192.168.100.232/192.168.100.232:99 после 60000ms в org.asynchttpclient.netty.timeout.TimeoutTimerTask.expire (TimeoutTimerTask.java:43) [1990: wrap_file__home_ossl_.m2_repository_org_asynchttpclient_async-http-client -2_2-client.2.2.async.port-http.4.3: 0.0.0] at org.asynchttpclient.netty.timeout.RequestTimeoutTimerTask.run (RequestTimeoutTimerTask.java:50) [1990: wrap_file__home_ossl_.m2_repository_org_asynchttpclient_async-http-client-2.4_ клиентский_порт_пакет_пакет_пакет_пакет_процессе_пакет_пакет_процессе_пакет_пакет_2-клиенту_сервис_пакет_пакет_процессе_пакет_пакет_2-клиенте_сервис_2_2.2.jp.asynchttpclient .__ version_2.4.3: 0.0.0] в io.netty.util.HashedWheelTimer $ HashedWheelTimeout.expire (HashedWheelTimer.java:663) [654: io.netty.common: 4.1.16.Final-redhat-2] вio.netty.util.HashedWheelTimer $ HashedWheelBucket.expireTimeouts (HashedWheelTimer.java:738) [654: io.netty.common: 4.1.16.Final-redhat-2] на io.netty.util.HashedWheelTimer $ Worker.run (HashedWheelTimer.java:466) [654: io.netty.common: 4.1.16.Final-redhat-2] в io.netty.util.concurrent.DefaultThreadFactory $ DefaultRunnableDecorator.run (DefaultThreadFactory.java:138) [654: io.netty.common: 4.1.16.Final-redhat-2] в java.lang.Thread.run(Thread.java:748) [?:?] 10: 35: 19.203 ОШИБКА [AsyncHttpClient-timer-87-1] Не удалось доставить (MessageId: ID-localhost-localdomain-1552973873885-38-117 в ExchangeId: ID-localhost-localdomain-1552973873885-38-114).Исчерпано после попытки доставки: 1 перехвачено: java.util.concurrent.TimeoutException: время ожидания запроса до 192.168.100.232/192.168.100.232:9999 после 60000 мс </p>