Using camel-cdi on Wildfly-10.1

Hello, I want to use Camel 2.18.3 on WildFly-10.1.0.Final. My desired setup is as follow: - to use camel-cdi features - to deploy camel and all third party dependencies as WildFly modules - to deploy my application as war on WildFly with all internal dependencies as jars in web-inf/lib - I do not

Re: Re throwing exception

Have you tried using the “NoErrorHandler”? http://camel.apache.org/error-handler.html > On May 4, 2017, at 10:34 AM, las wrote: > > I have a route and an onException definition. My exception processor is > getting called. But the exception or error

hystrix fallback configuration for camel dynamic router returning multiple endpoints

Hello, How do we configure hystrix fallback for dynamic router invoking multiple endpoints, the catch with dynamic router is how to identify failures out of multiple endpoint invocations. *camel route:* from(rmq:localhost/exchange?queue=somequeue).bean(SomeDynamicRouter.class) class SomeDynamicRo

apache camel websocket over stomp with user password

Hi guys! I would like to subscribe to a websocket that is running over stomp, but i'm having multiple issues: The URI i have to connect to is ws://desa-datahub.donostia.eus/stomp with the credentials (user/myPassword) and with the topic :topic/myTopic How can i do it with apache camel? Rega

Re throwing exception

I have a route and an onException definition. My exception processor is getting called. But the exception or error I throw in exception processor is not getting bubbled to the client. RouteBuilder builder = new RouteBuilder() { public void configure() { // onException(Exception

Re: How to increase camel exchange timeout threshold

souciance, Thanks for the feed back. I will try that change. Do you know if there is a way to do it at the route level? -- View this message in context: http://camel.465427.n5.nabble.com/How-to-increase-camel-exchange-timeout-threshold-tp5798620p5798654.html Sent from the Camel - Users maili

AW: Charset on file poller endpoint

Yes, a Bean is probably the best way to do the work. However, I tried to inject the exchange, get the body as InputStream and read the first 4 bytes from the body (because an InputStream is a byte representation and therefore not encoded). When I read a file that is UTF-16 (Big endian) encoded

Re: Unable to insert body data into table using sql component

Yes you need to build your own conversion from byte[] to Map to store the data as you need it. there is no possible way for camel or java to convert a byte array into a map structure. See this EIP http://camel.apache.org/message-translator.html On Thu, May 4, 2017 at 9:44 AM, darwinanirudh wrot

Re: Unable to insert body data into table using sql component

Sorry my mistake , it was M only ... Yes i tried , but it says there is no type conversion from Byte[] to Map. regards Darwin -- View this message in context: http://camel.465427.n5.nabble.com/Unable-to-insert-body-data-into-table-using-sql-component-tp5798623p5798647.html Sent from the Camel

Re: Unable to insert body data into table using sql component

I tried but i am getting the following error : Caused by: No type converter available to convert from type: byte[] to the required type: java.util.Map with value [B@1190966. Exchange[Message: {"callDate":"2017-12-08","callDuration":"400","callTime":"17:50:15","aNum":"1241972582","bNum":"0041

Re: REG: Aggregator not working fine in camel version 2.8.3

You cannot use 2 different routes and use the complete from batch consumer and expect that this "somehow magically" knows there are 2 routes. That completion is only for a single route and its group of batch message that was polled. Instead of 2 routes, use 1 route. And you can use a filter to ma

Re: TimeOut in ConsumerTemplate not working (Takes forever)

Hi Its not a hard timeout. The timout is passed down to the component being used if possible and it tries to honor that. In this case its a timeout for the socket connection // set optional timeout in millis if (timeout > 0) { method.getParams().setSoTimeout(timeout);

Re: How to implement DataFormat

Hi Its up to you how you implement your own data formats. Camel uses the DataFormat API that has marshal and unmarshal operations. Whatever you do there is up to you. >From your email it sound like you mix up a few things and its a bit hard to explain in an email. The aggreagator EIP is the guy

Re: Ref cursor in stored proc out param

Hi I dont think cursor is supported in the Camel component as outputs. On Wed, May 3, 2017 at 11:13 AM, pamposh wrote: > Hi, > > I am calling oracle stored procedure with ref_cursor OUT parameter, using > camel sql-stored but getting following error.How to use ref cursor with > camel? > > *SQL:*

Re: Unable to insert body data into table using sql component

The Map must be using a big M letter. On Thu, May 4, 2017 at 9:21 AM, darwinanirudh wrote: > Thanks a lot for the reply. > > i have already used before the sql > clause . > > Or am i wrong ? Can you please elaborate . > > regards > Darwin > > > > > -- > View this message in context: > http:

Re: Disabling coma delimiter in @RecipientList-annotated methods that return String

Hi Okay I took at look in the source, and you can use the value "false" to turn it off. I have updated the javadoc to include that information. On Thu, May 4, 2017 at 7:05 AM, Claus Ibsen wrote: > You can look at the @RecipientList and see which attributes it has you > can configure. > > On Wed,

Re: Unable to insert body data into table using sql component

Thanks a lot for the reply. i have already used before the sql clause . Or am i wrong ? Can you please elaborate . regards Darwin -- View this message in context: http://camel.465427.n5.nabble.com/Unable-to-insert-body-data-into-table-using-sql-component-tp5798

mongodb distinct query

I'm trying to figure out if Camel supports distinct queries with the mongodb component. I've looked through the docs and source code and cannot see where that is supported. Is this functionality supported in the camel-mongodb component and I just don't see it? Cheers, Mark

Re: Unable to insert body data into table using sql component

Try with java.util.Map. On Thu, May 4, 2017 at 1:51 AM, darwinanirudh wrote: > Dear All, > > > I need to insert the body values into table so i used sql component. > > Since the data in the body should be of map data type , i tried the > following and i am getting the exception: > > Caused by: o

Re: Disabling coma delimiter in @RecipientList-annotated methods that return String

You can look at the @RecipientList and see which attributes it has you can configure. On Wed, May 3, 2017 at 12:19 PM, furchess123 wrote: > The Recipient List > > documentation states: > > /Notice that the Recipient List can send to m

Unable to insert body data into table using sql component

Dear All, I need to insert the body values into table so i used sql component. Since the data in the body should be of map data type , i tried the following and i am getting the exception: Caused by: org.apache.camel.FailedToCreateRouteException: Failed to create route webproxyTest at: >>> Con

Netty4-HTTP component for HTTPS Issues

Hi , I am trying to configure the Netty4-Http for https url. I am using the tomcat server on the server side with port 8443 configured for https. I have created the certificate from the server machine and used the path in client machine for configuring the keystore. I am able to work with Netty4-H

Ref cursor in stored proc out param

Hi, I am calling oracle stored procedure with ref_cursor OUT parameter, using camel sql-stored but getting following error.How to use ref cursor with camel? *SQL:* public static final String TEST_SQL = "getEvtSummary(OUT ref_cursor res,INTEGER ${headers.p_evt_id},INTEGER ${headers.p_status_id})";

Re: Sometimes the data in body is null..

Thanks for the suggestion. yeah currently i am trying to log all the details .. I suspect network connection . I need to handle 10 messages(~600 byte) /s received on the rest endpoint, aggregate these in batches 100 then, add some metadata and publish on a message bus. This will have to run 24/7

Re: How to increase camel exchange timeout threshold

Try setting this method to a value of your choice. https://camel.apache.org/maven/camel-2.15.0/camel-core/apidocs/org/apache/camel/impl/DefaultShutdownStrategy.html#setTimeout(long) Exchange timeouts are set att Camel context level and not the seda level. On Wed, May 3, 2017 at 6:39 PM, Ryan T [

Re: Charset on file poller endpoint

Probably the easiest is to read the file and send the exchange to a bean. In the bean try to read it and determine the encoding and if it has a BOM character. Finally do your conversion and put the body back to the exchange. from(file:/myDir) .to(DetermineEncoding.class, "determineEncoding") .to(a

Re: Sometimes the data in body is null..

I guess it could be network errors or something else that takes time? Maybe add more logging such as log the the headers, properties, timestamp or the old exchange, to give you a clue why this exchange body was empty. Maybe some other business logic that caused it? What is it you want to accomplis

Charset on file poller endpoint

Hi Camel users I read files with a Camel file poller and they can have different encodings (UTF-8 with or without BOM, UTF-16). Therefore I would like to determine the given encoding and convert the message body to UTF-8 without BOM for the further processing. How can I do this and what is exa