[
https://issues.apache.org/jira/browse/CAMEL-12712?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16573311#comment-16573311
]
Jesse Sightler edited comment on CAMEL-12712 at 8/8/18 2:45 PM:
----------------------------------------------------------------
[~zregvart] - Yes, and that is the bug report. :) The reason the http request
is never received is that the thread that would process the request is stuck
waiting on the response (inside of aggregator). The thread won't unblock until
it receives a response and also won't process a response until it is unblocked.
If you switch to a seda queue so that the original thread is unblocked, then
the response is received. It seems to be an issue with the way the aggregator
works with the netty client.
was (Author: [email protected]):
[~zregvart] - Yes, and that is the bug report. :) The reason the http request
is never received is that the thread that would process the request is stuck
waiting on the response.
If you switch to a seda queue so that the original thread is unblocked, then
the response is received. It seems to be an issue with the way the aggregator
works with the netty client.
> Camel Salesforce can easily hang when used within an aggregator
> ---------------------------------------------------------------
>
> Key: CAMEL-12712
> URL: https://issues.apache.org/jira/browse/CAMEL-12712
> Project: Camel
> Issue Type: Bug
> Components: camel-salesforce
> Reporter: Jesse Sightler
> Priority: Major
>
> Reproducer project:
> https://github.com/jsight/camel-salesforce-http-aggregator-issue
>
> Run the unit tests and you will observe it hanging.
>
> A workaround is also present. Uncomment this line:
> {quote}// .to("seda:enrichWithJobId?waitForTaskToComplete=Always")
> {quote}
>
> The code that hangs is this:
> {quote}.enrich("direct:createJobAndGetID", new AggregationStrategy() {
> @Override
> public Exchange aggregate(Exchange oldExchange, Exchange newExchange)
> Unknown macro: \{ oldExchange.getIn().setHeader("jobId",
> newExchange.getIn().getBody(JobInfo.class).getId()); return oldExchange; }
> })
> {quote}
>
>
>
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
