topic Re: cDynamicRouter and different endpoints in Talend Studio

cDynamicRouter and different endpoints

Anonymous — Sat, 16 Nov 2024 11:06:04 GMT

Hi all,
I have the route (attached bellow).
I have to dynamically redirect the messages depending on the Http verb (I tried to do it using another approch but it was an epic fail )
used the link
The problem is that only the "DELETE" method is working, and yet I have the error:

 :1:1: Fin prématurée du fichier.
: org.apache.camel.processor.DefaultErrorHandler - Failed delivery for (MessageId: ID-LFR204094-55535-1439324535115-0-3 on ExchangeId: ID-LFR204094-55535-1439324535115-0-1). Exhausted after delivery attempt: 1 caught: org.apache.camel.CamelExecutionException: Exception occurred during execution on the exchange: Exchange]

while with the GET or POST methods all I have is this error:

 :1:1: Contenu non autorisé dans le prologue.
: org.apache.camel.processor.DefaultErrorHandler - Failed delivery for (MessageId: ID-LFR204094-56301-1439325581670-0-3 on ExchangeId: ID-LFR204094-56301-1439325581670-0-1). Exhausted after delivery attempt: 1 caught: org.apache.camel.CamelExecutionException: Exception occurred during execution on the exchange: Exchange]

I bridged the URLs:

"http://localhost:8081/webMavenChouette?bridgeEndpoint=true&throwExceptionOnFailure=false"

please find attached the snapshots of the route and the bean:

Thank you for your time
-Regards

Re: cDynamicRouter and different endpoints

Anonymous — Wed, 12 Aug 2015 09:55:57 GMT

I addedd a cErrorHandler:

Here's what I got as logs

: org.eclipse.jetty.server.AbstractConnector - Started SelectChannelConnector@localhost:8084
: org.apache.camel.spring.SpringCamelContext - Route: Base_cHttp_1 started and consuming from: Endpoint
: org.apache.camel.spring.SpringCamelContext - Route: POST_cMessagingEndpoint_1 started and consuming from: Endpoint
: org.apache.camel.spring.SpringCamelContext - Route: GET_cMessagingEndpoint_2 started and consuming from: Endpoint
: org.apache.camel.spring.SpringCamelContext - Route: DELETE_cMessagingEndpoint_3 started and consuming from: Endpoint
: org.apache.camel.spring.SpringCamelContext - Total 4 routes, of which 4 is started.
: org.apache.camel.spring.SpringCamelContext - Apache Camel 2.15.2 (CamelContext: RouteChouetteSplit-ctx) started in 1.790 seconds
: chouetteRoute.cLog_7 - GET CLIENT
: org.apache.commons.httpclient.HttpMethodDirector - I/O exception (java.net.ConnectException) caught when processing request: Connection refused: connect
: org.apache.commons.httpclient.HttpMethodDirector - Retrying request
: org.apache.commons.httpclient.HttpMethodDirector - I/O exception (java.net.ConnectException) caught when processing request: Connection refused: connect
: org.apache.commons.httpclient.HttpMethodDirector - Retrying request
: org.apache.commons.httpclient.HttpMethodDirector - I/O exception (java.net.ConnectException) caught when processing request: Connection refused: connect
: org.apache.commons.httpclient.HttpMethodDirector - Retrying request
: org.slf4j.Logger - Failed delivery for (MessageId: ID-LFR204094-53626-1439369472006-0-2 on ExchangeId: ID-LFR204094-53626-1439369472006-0-1). Exhausted after delivery attempt: 1 caught: java.net.ConnectException: Connection refused: connect
Message History
---------------------------------------------------------------------------------------------------------------------------------------
RouteId              ProcessorId          Processor                                                                        Elapsed (ms)
   
                                           ] 
   
                                                      ] 
   
Exchange
---------------------------------------------------------------------------------------------------------------------------------------
Exchange
]
Stacktrace
---------------------------------------------------------------------------------------------------------------------------------------
java.net.ConnectException: Connection refused: connect
	at java.net.DualStackPlainSocketImpl.connect0(Native Method)
	at java.net.DualStackPlainSocketImpl.socketConnect(Unknown Source)
	at java.net.AbstractPlainSocketImpl.doConnect(Unknown Source)
	at java.net.AbstractPlainSocketImpl.connectToAddress(Unknown Source)
	at java.net.AbstractPlainSocketImpl.connect(Unknown Source)
	at java.net.PlainSocketImpl.connect(Unknown Source)
	at java.net.SocksSocketImpl.connect(Unknown Source)
	at java.net.Socket.connect(Unknown Source)
	at java.net.Socket.connect(Unknown Source)
	at java.net.Socket.(Unknown Source)
	at java.net.Socket.(Unknown Source)
	at org.apache.commons.httpclient.protocol.DefaultProtocolSocketFactory.createSocket(DefaultProtocolSocketFactory.java:80)
	at org.apache.commons.httpclient.protocol.DefaultProtocolSocketFactory.createSocket(DefaultProtocolSocketFactory.java:122)
	at org.apache.commons.httpclient.HttpConnection.open(HttpConnection.java:707)
	at org.apache.commons.httpclient.MultiThreadedHttpConnectionManager$HttpConnectionAdapter.open(MultiThreadedHttpConnectionManager.java:1361)
	at org.apache.commons.httpclient.HttpMethodDirector.executeWithRetry(HttpMethodDirector.java:387)
	at org.apache.commons.httpclient.HttpMethodDirector.executeMethod(HttpMethodDirector.java:171)
	at org.apache.commons.httpclient.HttpClient.executeMethod(HttpClient.java:397)
	at org.apache.commons.httpclient.HttpClient.executeMethod(HttpClient.java:323)
	at org.apache.camel.component.http.HttpProducer.executeMethod(HttpProducer.java:244)
	at org.apache.camel.component.http.HttpProducer.process(HttpProducer.java:144)
	at org.apache.camel.util.AsyncProcessorConverterHelper$ProcessorToAsyncProcessorBridge.process(AsyncProcessorConverterHelper.java:61)
	at org.apache.camel.processor.SendProcessor.process(SendProcessor.java:129)
	at org.apache.camel.management.InstrumentationProcessor.process(InstrumentationProcessor.java:77)
	at org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:91)
	at routines.system.CamelStat$1$1.process(CamelStat.java:56)
	at org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:91)
	at org.apache.camel.processor.RedeliveryErrorHandler.process(RedeliveryErrorHandler.java:448)
	at org.apache.camel.processor.CamelInternalProcessor.process(CamelInternalProcessor.java:191)
	at org.apache.camel.processor.Pipeline.process(Pipeline.java:118)
	at org.apache.camel.processor.Pipeline.process(Pipeline.java:80)
	at org.apache.camel.processor.CamelInternalProcessor.process(CamelInternalProcessor.java:191)
	at org.apache.camel.component.direct.DirectProducer.process(DirectProducer.java:51)
	at org.apache.camel.processor.RoutingSlip$2.doInAsyncProducer(RoutingSlip.java:301)
	at org.apache.camel.impl.ProducerCache.doInAsyncProducer(ProducerCache.java:304)
	at org.apache.camel.processor.RoutingSlip.processExchange(RoutingSlip.java:294)
	at org.apache.camel.processor.RoutingSlip.doRoutingSlip(RoutingSlip.java:215)
	at org.apache.camel.processor.RoutingSlip.process(RoutingSlip.java:146)
	at org.apache.camel.management.InstrumentationProcessor.process(InstrumentationProcessor.java:77)
	at org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:91)
	at routines.system.CamelStat$1$1.process(CamelStat.java:56)
	at org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:91)
	at org.apache.camel.processor.RedeliveryErrorHandler.process(RedeliveryErrorHandler.java:448)
	at org.apache.camel.processor.CamelInternalProcessor.process(CamelInternalProcessor.java:191)
	at org.apache.camel.processor.CamelInternalProcessor.process(CamelInternalProcessor.java:191)
	at org.apache.camel.component.jetty.CamelContinuationServlet.service(CamelContinuationServlet.java:162)
	at javax.servlet.http.HttpServlet.service(HttpServlet.java:848)
	at org.eclipse.jetty.servlet.ServletHolder.handle(ServletHolder.java:686)
	at org.eclipse.jetty.servlet.ServletHandler$CachedChain.doFilter(ServletHandler.java:1494)
	at org.eclipse.jetty.servlets.MultiPartFilter.doFilter(MultiPartFilter.java:136)
	at org.apache.camel.component.jetty.CamelFilterWrapper.doFilter(CamelFilterWrapper.java:43)
	at org.eclipse.jetty.servlet.ServletHandler$CachedChain.doFilter(ServletHandler.java:1465)
	at org.eclipse.jetty.servlet.ServletHandler.doHandle(ServletHandler.java:499)
	at org.eclipse.jetty.server.handler.ContextHandler.doHandle(ContextHandler.java:1086)
	at org.eclipse.jetty.servlet.ServletHandler.doScope(ServletHandler.java:428)
	at org.eclipse.jetty.server.handler.ContextHandler.doScope(ContextHandler.java:1020)
	at org.eclipse.jetty.server.handler.ScopedHandler.handle(ScopedHandler.java:135)
	at org.eclipse.jetty.server.handler.HandlerWrapper.handle(HandlerWrapper.java:116)
	at org.eclipse.jetty.server.Server.handle(Server.java:370)
	at org.eclipse.jetty.server.AbstractHttpConnection.handleRequest(AbstractHttpConnection.java:489)
	at org.eclipse.jetty.server.AbstractHttpConnection.headerComplete(AbstractHttpConnection.java:949)
	at org.eclipse.jetty.server.AbstractHttpConnection$RequestHandler.headerComplete(AbstractHttpConnection.java:1011)
	at org.eclipse.jetty.http.HttpParser.parseNext(HttpParser.java:644)
	at org.eclipse.jetty.http.HttpParser.parseAvailable(HttpParser.java:235)
	at org.eclipse.jetty.server.AsyncHttpConnection.handle(AsyncHttpConnection.java:82)
	at org.eclipse.jetty.io.nio.SelectChannelEndPoint.handle(SelectChannelEndPoint.java:668)
	at org.eclipse.jetty.io.nio.SelectChannelEndPoint$1.run(SelectChannelEndPoint.java:52)
	at org.eclipse.jetty.util.thread.QueuedThreadPool.runJob(QueuedThreadPool.java:608)
	at org.eclipse.jetty.util.thread.QueuedThreadPool$3.run(QueuedThreadPool.java:543)
	at java.lang.Thread.run(Unknown Source)

-Regards

Re: cDynamicRouter and different endpoints

Anonymous — Thu, 13 Aug 2015 14:19:25 GMT

well, as it's said in the docs, the cMessagingEndpoint allows two applications to communicate by either sending or receiving messages, one endpoint can not do both. so I replaced it with a cHttp component, as a server (please find the picture attached).
The route worked one time as expected with no errors, after a restart of my computer, it gives me this errors:

Démarrage du job testDynamicRouter a 15:12 13/08/2015.: org.apache.camel.main.MainSupport - Apache Camel 2.15.2 starting: org.springframework.context.support.ClassPathXmlApplicationContext - Refreshing org.springframework.context.support.ClassPathXmlApplicationContext@38d760bb: startup date ; root of context hierarchy: org.springframework.beans.factory.xml.XmlBeanDefinitionReader - Loading XML bean definitions from class path resource : org.springframework.beans.factory.support.DefaultListableBeanFactory - Pre-instantiating singlet

To see the whole post, download it here
OriginalPost.pdf

Re: cDynamicRouter and different endpoints

Anonymous — Thu, 13 Aug 2015 16:03:33 GMT

What is the difference between the DELETE, GET and POST cHttp components? How are each of them configured? What type of data is sent? Are they set up as Client rather than Server?

Re: cDynamicRouter and different endpoints

Anonymous — Thu, 13 Aug 2015 16:16:17 GMT

Thank you for your answer
the cHttp DELETE , POST and GET are all set up as "client", they all have the same URI:

URI="http://localhost:8081/webMavenChouette?bridgeEndpoint=true&throwExceptionOnFailure=false"

calling a REST web service.
The difference is the configuration, the one called "DELETE" uses the methode "DELETE", the one called "POST" uses the methode "POST", the one called "GET" uses the methode "GET". They will be used to differenciate the processing according to the HTTP verb used
the data sent is json objects.
-Regards

Re: cDynamicRouter and different endpoints

Anonymous — Thu, 13 Aug 2015 16:41:10 GMT

Have you tested each of the http verbs with the service you are sending them to without this process? It could be a problem with that service.

Re: cDynamicRouter and different endpoints

Anonymous — Thu, 13 Aug 2015 16:59:39 GMT

Actually I've already tested the service itself using a route :
chttp (server) -> chttp(client) -> cMessageRouter ->2 when branches to test the Exchange.HTTP_RESPONSE_CODE ->cLogs
and it's working just fine with the 3 http verbs
The problem occurs when I introduce the cDynamicRouter. to do the if/else conditions, I used a bean, using the cBeanRegister" component, which redirects the message

public String setURI(Document document,@Header(Exchange.SLIP_ENDPOINT) String previous, 
			@Header(Exchange.HTTP_METHOD) String httpVerb) {
		
		if (previous != null) {
			return null;
		}
	
		return "direct:" + httpVerb;

it returns a "direct:GET" (if the request was a GET) that is put in the "GET_server": a chttp server component ;
please reconsider the snapshots, I renamed the chttp component depending on their configuration.

Re: cDynamicRouter and different endpoints

Anonymous — Thu, 13 Aug 2015 17:12:11 GMT

Where is the service you are calling running? Is it running in the Studio or in the Karaf? Do you have more than one service; 1 for each verb?
Also, can you add the following code to your routine?

public String setURI(Document document,@Header(Exchange.SLIP_ENDPOINT) String previous, 
			@Header(Exchange.HTTP_METHOD) String httpVerb) {
		
		if (previous != null) {
			return null;
		}
	
System.out.out.println("direct:"+httpVerb); //<--- This code to see what is produced
		return "direct:" + httpVerb;
}

Re: cDynamicRouter and different endpoints

Anonymous — Thu, 13 Aug 2015 23:23:19 GMT

my service is running in eclipse, it's a spring mvc application, with Rest controllers
and the System.out.out.println("direct:"+httpVerb); prints the http verb I'm using in the request in the Rest Client DHC
==> if it's a GET request then the code prints "direct:GET"

Re: cDynamicRouter and different endpoints

Anonymous — Fri, 14 Aug 2015 00:20:40 GMT

I *think* I might have the answer, but I can't test it here. Looking at your error messages it looks like the service is throwing errors because it is expecting a String but is receiving the body as an instance of java.io.InputStream. To work around this, try putting cProcessor components before your POST_client, GET_client and DELETE_client components. In each of the cProcessor components, put the following code.....

String jsonString = exchange.getIn().getBody(String.class);
exchange.getIn().setBody(jsonString);

What you are doing here is forcing the body to be converted to a String (from an instance of java.io.InputStream) and then putting it back into the "in" message as a String.
This won't necessarily get it to work perfectly, but you should see it get further after this.
Let me know if it works.

Re: cDynamicRouter and different endpoints

Anonymous — Fri, 14 Aug 2015 12:32:48 GMT

I tested your hint but I still have the exact same error, but I don't think your guess is right because even when I keep just the GET_server, I still have the same error message

Re: cDynamicRouter and different endpoints

Anonymous — Fri, 14 Aug 2015 13:33:36 GMT

You cannot have the cHttp components as POST_Server, GET_Server and DELETE_SERVER. These should be cMessagingEndpoint components. cMessagingEndpoint components allow you to use the direct endpoint. They are generic endpoints that allow you to use any of the Camel Components. The cHttp components are for producing or consuming service calls. Although you are working with services here, you are actually using the Camel direct component to pass the messages from the cDynamicRouter. Therefore you must use the cMessagingEndpoint.

Re: cDynamicRouter and different endpoints

Anonymous — Fri, 14 Aug 2015 13:43:35 GMT

I've already used the cMessagingEndpoint (please see the first message) but this component allows two applications to communicate by either sending or receiving messages, one endpoint can not do both, so I cannot have "an answer" from the service web, and *I think* that's why only the DELETE method worked for me
I jest retested with a cMessagingEndpoint component and a GET request:

: org.apache.camel.main.MainSupport - Apache Camel 2.15.2 starting
: org.springframework.context.support.ClassPathXmlApplicationContext - Refreshing org.springframework.context.support.ClassPathXmlApplicationContext@7bc0bd17: startup date ; root of context hierarchy: org.springframework.beans.factory.xml.XmlBeanDefinitionReader - Loading XML bean definitions from class path resource : org.springframework.beans.factory.support.DefaultListableBeanFactory - Pre-instantiating singletons in org.springframework.beans.factory.support.Defaul

To see the whole post, download it here
OriginalPost.pdf

Re: cDynamicRouter and different endpoints

Anonymous — Fri, 14 Aug 2015 13:58:04 GMT

I also tried a "sipmler" way, using a cMessagingRouter component:

However, the route just behaves weirdly,it does not work depending on the corresponding logic to the graph.for example: the branch "when2" is called only when the two conditions "when4" and "when5" are false (dspite the fact that in my Rest Client, the http verb is "DELETE".
When I looked into the code, it appers that it's a little bit *messy*, it's not clear which ".when(...)" is related to which ".choice()":

public void configure() throws java.lang.Exception {
		from(uriMap.get("cHttp_3"))
				.routeId("Base_cHttp_3")
				.choice()
				.id("cMessageRouter_1")
				.when()
				.simple("${header." + org.apache.camel.Exchange.HTTP_METHOD
						+ "} == 'GET'")
				.setHeader("CamelHttpMethod", constant("GET"))
				.to(uriMap.get("cHttp_4"))
				.id("cHttp_4")
				.choice()
				.id("cMessageRouter_2")
				.when()
				.simple("${header."
						+ org.apache.camel.Exchange.HTTP_RESPONSE_CODE
						+ "} == 200 ")
				.log(org.apache.camel.LoggingLevel.INFO,
						"chouetteRoute.cLog_1", "good")
				.id("cLog_2")
				.when()
				.simple("${header."
						+ org.apache.camel.Exchange.HTTP_RESPONSE_CODE
						+ "} == 200 ")
				.log(org.apache.camel.LoggingLevel.ERROR,
						"chouetteRoute.cLog_1", "eRREUR")
				.id("cLog_9")
				.when()
				.simple("${header." + org.apache.camel.Exchange.HTTP_METHOD
						+ "} == 'POST'")
				.setHeader("CamelHttpMethod", constant("POST"))
				.setHeader("Content-Type", constant("application/json"))
				.to(uriMap.get("cHttp_7"))
				.id("cHttp_7")
				.choice()
				.id("cMessageRouter_4")
				.when()
				.simple("${header."
						+ org.apache.camel.Exchange.HTTP_RESPONSE_CODE
						+ "} == 200 ")
				.log(org.apache.camel.LoggingLevel.INFO,
						"chouetteRoute.cLog_1", "good")
				.id("cLog_5")
				.when()
				.simple("${header."
						+ org.apache.camel.Exchange.HTTP_RESPONSE_CODE
						+ "} == 404 ")
				.log(org.apache.camel.LoggingLevel.ERROR,
						"chouetteRoute.cLog_1", "eRREUR")
				.id("cLog_6")
				.when()
				.simple("${header." + org.apache.camel.Exchange.HTTP_METHOD
						+ "} == 'DELETE'")
				.setHeader("CamelHttpMethod", constant("DELETE"))
				.to(uriMap.get("cHttp_1"))
				.id("cHttp_1")
				.choice()
				.id("cMessageRouter_3")
				.when()
				.simple("${header."
						+ org.apache.camel.Exchange.HTTP_RESPONSE_CODE
						+ "} == 200 ")
				.log(org.apache.camel.LoggingLevel.INFO,
						"chouetteRoute.cLog_1", "good")
				.id("cLog_3")
				.when()
				.simple("${header."
						+ org.apache.camel.Exchange.HTTP_RESPONSE_CODE
						+ "} == 404 ")
				.log(org.apache.camel.LoggingLevel.ERROR,
						"chouetteRoute.cLog_1", "eRREUR")
				.id("cLog_4");
	}

Re: cDynamicRouter and different endpoints

Anonymous — Fri, 14 Aug 2015 14:05:31 GMT

If you look at the screenshot, you can see that the cMessagingEndpoint is working as it should. That is why you are getting row counts after the cMessagingEndpoint. You are getting confused with the terminology. The cMessagingEndpoint is fine and should stay.
However, I can now see that the service is expecting the body as an instance of org.w3c.dom.Document . Your service (in Eclipse) is expecting XML as its payload. You need to inform it that you are sending JSON. To do this you might want to try going to the advanced settings of your cHttp components that are calling your Eclipse service and create a new header called "Content-Type" and assigning it a value of "application/json".
The error message below explains that the service wants the body as org.w3c.dom.Document and that is why you are getting this error. You must be really careful to identify the precise error when debugging. This is a completely different error to the one before.
Caused by: org.apache.camel.InvalidPayloadException: No body available of type: org.w3c.dom.Document but has value: org.apache.camel.converter.stream.CachedOutputStream$WrappedInputStream@6c15234e of type: org.apache.camel.converter.stream.CachedOutputStream.WrappedInputStream on: Message: . Caused by: Error during type conversion from type: java.lang.String to the required type: org.w3c.dom.Document with value due org.xml.sax.SAXParseException; lineNumber: 1; columnNumber: 1; Contenu non autorisé dans le prologue.. Exchange]. Caused by: due org.xml.sax.SAXParseException; lineNumber: 1; columnNumber: 1; Contenu non autorisé dans le prologue.]

Re: cDynamicRouter and different endpoints

Anonymous — Fri, 14 Aug 2015 14:24:07 GMT

I must say that I'm confused since when I request the service directly in the browser, without Talend, I get json data

** the new header "Content-Type":"application/json" in the cHttp component Get_client doesn't resolve the problem, still getting the error

To see the whole post, download it here
OriginalPost.pdf

Re: cDynamicRouter and different endpoints

Anonymous — Fri, 14 Aug 2015 14:27:28 GMT

Your browser will only ever make a GET call. You are also not sending a payload or a body. When testing REST services that are anything other than GET you really need to use a tool that makes it easy to specify the http verb and supply a payload. Something like Advanced Rest Client (https://chrome.google.com/webstore/detail/advanced-rest-client/hgmloofddffdnphfgcellkdfbfbjeloo) for Chrome works for me.

Re: cDynamicRouter and different endpoints

Anonymous — Fri, 14 Aug 2015 14:34:57 GMT

I was actually using DHC rest Client to specify the HTTP Verb I want to use, sorry didn't mention it before
I used DHC Rest Client to make a direct POST (without using talend) in the service (in eclipse) using json data, it works:

Re: cDynamicRouter and different endpoints

Anonymous — Fri, 14 Aug 2015 14:41:43 GMT

You need to copy the exact settings you use in that to get it to work in Talend. I have just looked at that app and noticed that when you click on the JSON link under the payload, it sets the Content-Type up for you. This will need to be set when you run it via any other system.

Re: cDynamicRouter and different endpoints

Anonymous — Fri, 14 Aug 2015 15:06:10 GMT

well, I added a header in the chttp client component, as you can see in the snapshot, in the POST_server component, the configuration is already set to "application/json"
is there something else I should set?

here's what I got in the debug:

: org.eclipse.jetty.server.AbstractConnector - Started SelectChannelConnector@localhost:8087
: org.apache.camel.spring.SpringCamelContext - Route: base_cHttp_1 started and consuming from: Endpoint
: org.apache.camel.spring.SpringCamelContext - Route: cMessagingEndpoint_1 started and consuming from: Endpoint
: org.apache.camel.spring.SpringCamelContext - Route: cMessagingEndpoint_2 started and consuming from: Endpoint
: org.apache.camel.spring.SpringCamelContext - Route: cMessagingEndpoint_3 started and consuming from: Endpoint
: org.apache.camel.spring.SpringCamelContext - Total 4 routes, of which 4 is started.
: org.apache.camel.spring.SpringCamelContext - Apache Camel 2.15.2 (CamelContext: test2cDynamicRouter-ctx) started in 1.277 seconds
: cDynamicRouter.cLog_1 - Exchange]
 :43:7: Le type d'élément "meta" doit se terminer par la balise de fin correspondante "".
: org.apache.camel.processor.DefaultErrorHandler - Failed delivery for (MessageId: ID-LFR204094-53910-1439560830380-0-3 on ExchangeId: ID-LFR204094-53910-1439560830380-0-1). Exhausted after delivery attempt: 1 caught: org.apache.camel.CamelExecutionException: Exception occurred during execution on the exchange: Exchange]
Message History
---------------------------------------------------------------------------------------------------------------------------------------
RouteId              ProcessorId          Processor                                                                        Elapsed (ms)
   
                                           ] 
                                                      ] 
                                                         ] 
   
  choice 
   
Exchange
---------------------------------------------------------------------------------------------------------------------------------------
Exchange
]