On Mon, 2022-10-10 at 13:27 +0200, Stefan Kok wrote:
The reason why the second call to the route failed is that my code did
not update the rerence to the second exchang's exchange asyncCallback
i.e I used the previous asyncCallback.
> Hi Claus
>
> Thank you for the response.
>
> Background:
>
> We trying to translate between REST and Websockets (io.socket
> library)
> with a custom component in development.
>
>
> Calling the route:
>
> Exchange exchange = ExchangeBuilder
> .anExchange(producerTemplate.getCamelContext())
> .withPattern(ExchangePattern.InOut)
> .withBody(jsonNode)
> .build();
>
> CompletableFuture<Exchange> future =
> producerTemplate.asyncSend(EndPointUri.SEDA_START_END_POINT,
> exchange);
>
> The route is configured as follows:
> @Bean
> public RoutesBuilder ChangeAgentState() {
> return new RouteBuilder() {
> @Override
> public void configure() throws Exception {
> from(EndPointUri.SEDA_START_END_POINT)
> .routeId("ChangeAgentState")
> .process(new ChangeAgentStateProcessor())
> .to(cloudConfigClient.getWssUrl())
> .log(LoggingLevel.TRACE,"${body}");
> }
> };
>
> ChangeAgentStateProcessor converts the exchange message object from
> JsonNode to EventDto ( We will return EventDto to the caller)
>
> The first time the route is called the expected EventDto is received.
> The second time I call the route the object never arrives as per the
> exception below.
>
> Stefan
>
>
>
>
> On Mon, 2022-10-10 at 12:33 +0200, Claus Ibsen wrote:
> > It says that the message did not arrive, and that a timeout was
> > triggered
> > because of that.
> >
> > What kind of messaging protocol do you use? JMS, http, etc?
> >
> > On Mon, Oct 10, 2022 at 12:20 PM Stefan Kok
> > <stefan....@centilliard.io>
> > wrote:
> >
> > > Hi All
> > >
> > > I am having great difficulty making sense of the below log entry:
> > >
> > > 10-10-2022 11:53:11.497 WARN [ForkJoinPool.commonPool-worker-2]
> > > com.experflow.service.OcepService.lambda$changeAgentState$3(OcepS
> > > er
> > > vice
> > > .java:115) - Exception Message:
> > > org.apache.camel.ExchangeTimedOutException: The OUT message was
> > > not
> > > received within: 60000 millis. Exchange[8AFA941458EDDAE-
> > > 0000000000000002]
> > >
> > > What is the meaning?
> > >
> > > 1) The message arrived late but it did arrive.
> > > 2) The message did not arrive at all.
> > >
> > > Thank you in advance
> > >
> >
> >
>
