Unlock a world of possibilities! Login now and discover the exclusive benefits awaiting you.
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
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
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()":
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");
}
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
** 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
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:
I used DHC Rest Client to make a direct POST (without using talend) in the service (in eclipse) using json data, it works:
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.
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:
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
]