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(OcepSer
> > 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
> >
>
>
