Camel based transport adaptation for a distributed application

Hi, We have a distributed application that deals with huge volumes of telecom data based on Hadoop/HBase architecture. At the data ingest part, we want to be highly extensible w.r.t multiple transport support. In reality, data could be thrown at this system based on either JMS, SOAP, TCP, Files

Re: Java DSL / GroovyExpression / Binding

Hi, You don't need to copy the class, you can just override the evaluate method to setup the binding as you want. -- Willem Jiang Red Hat, Inc. Web: http://www.redhat.com Blog: http://willemjiang.blogspot.com (http://willemjiang.blogspot.com/) (English) http://jnn.iteye.com

Re: Java DSL / GroovyExpression / Binding

Hi Willem, thanks for your answer, unfortunately overriding eval is not sufficient as this method initializes everything and calls several private methods. By copy I meant: new ctor, copy eval, copy instantiateScript and copy createBinding to make it work which feels wrong. Furthermore my

Re: How to make Spring XML routing to be automatically reloaded

Hi See also this page, how you can load routes from xml http://camel.apache.org/loading-routes-from-xml-files.html And there is also JMX API where you can update a route from a piece of XML.

Re: [BLOG] Camel Routing Engine Part I

Nice blog. I added links to it and the other you did with the Java DSL to the Camel link collection at: http://camel.apache.org/articles On Mon, Aug 19, 2013 at 5:13 AM, Christian Posta christian.po...@gmail.com wrote: Hey all, for those interested, I put together some notes about how the

Re: Odd AMQ Transaction Behavior

The exception is being logged as an error and there are two warnings as well. The transaction rollback warning makes sense. Then the exception seems to trigger the second warning because I do not have a custom ErrorHandler configured. Sadly adding handled = true did not change this behavior.

Re: Conditional routing and local variables

Hi A good idea is to check the docs http://camel.apache.org/predicate.html For example you can use the front page of Apache Camel http://camel.apache.org/ And type in keywords in the search box. As well read some of the intro guides and whatnot. There is also a lot of links to external Camel

Using Camel File component to Poll a directory (but not read the files)

Hi, is it possible to use file component to poll for files in directories but NOT actually read the file? the file size is quite big - so I don't want to read the file - but I need a notification message (with the file name) Is there a way to achieve this using File component? or any other

Re: Using Camel File component to Poll a directory (but not read the files)

You can use noop=true, the message body is just java.io.File so the data wont be loaded in memory out of the box. On Mon, Aug 19, 2013 at 3:34 PM, deepak_a angesh...@gmail.com wrote: Hi, is it possible to use file component to poll for files in directories but NOT actually read the file? the

Re: Messages disappear if fabric endpoint resolves to null / blank

You should get an exception if the fabric registry entry is not exist. Can you double check the log to see if Camel throws the exception out? -- View this message in context: http://camel.465427.n5.nabble.com/Messages-disappear-if-fabric-endpoint-resolves-to-null-blank-tp5733683p5737512.html

Re: Using Camel File component to Poll a directory (but not read the files)

I think from looking at the code that the file content is not read at the time of polling. The content will not actually be read until you examine the body. So if you followed the file consumer with a setBody to change the body to something else, the content will never be read. On Mon, Aug 19,

When to use AWS SQS?

Hi, Apologies if I am posting this in the wrong forum (have just stared with AWS - though might get a better response here given that Camel supports SQS) I am analyzing the various components of AWS. My current architecture looks similar to the image in the below link

Re: When to use AWS SQS?

Hi, I think you should know the difference between the IAAS and SAAS[1]. When you using EC2, you don't need to take care of the physical machine any more, but you still need to install the OS, DB and Application Server to build up your service. But if you are using AWS SQS, you don't need

CookieStore

Hallo camel users, currently we use the http4-endpoint as proxy bridge endpoint for another webservice in a server side application. This service returns some cookies which seem to be stored in the cookie store of the httpclient. During the runtime of our server it seems to never clear the cookie

Re: When to use AWS SQS?

Hi, Thanks, that was useful. We are providing our Software as a Saas. Its sometimes hosted/deployed within our firm and at times deployed at the client's site. Now we plan to deploy our software in the cloud and provide it as a service to clients. I am still trying to understand if there is

Re: When to use AWS SQS?

AWS SQS has different characteristics than ActiveMQ, you have to consider those too. It is priced per message, doesn't support FIFO, much slower, but distributed and HA... Cheers Bilgin On 19 August 2013 16:11, deepak_a angesh...@gmail.com wrote: Hi, Thanks, that was useful. We are

Re: When to use AWS SQS?

Another thing to consider is that SQS is great for some situations, but consider these facts: Message size cannot be greater than 256K Messages are not delivered in order Your throughput and latency requirements (need to be fast?) need to be considered.. On Mon, Aug 19, 2013 at 8:11 AM,

Property Placeholder for Aggregation Completion Timeout Value in Blueprint

I'm using Camel 2.10.4 with my routes defined in Blueprint. I'm trying to use a property placeholder to configure the completionTimeout for my aggregator, and it's complaining: Camel (postingResultsCamelContext) thread #6 - seda://start ERROR [org.apache.camel.processor.DefaultErrorHandler] -

Re: Property Placeholder for Aggregation Completion Timeout Value in Blueprint

Hi Can you try upgrading to 2.10.5, see the blue box here about the xs:int type attribute when OSGi Blueprint is in use: http://camel.apache.org/using-propertyplaceholder.html#UsingPropertyPlaceholder-UsingpropertyplaceholdersforanykindofattributeintheXMLDSL Babak Scott Parkerson-4 wrote I'm

Re: Authenticating websockets endpoints.

I want to share my solution. I did not find a way to authenticate the Upgrade message and the websocket messages do not send headers. So I add the basic authentication to my message payload. The code is: * package com.revinate.sifter.auth; import

Re: Property Placeholder for Aggregation Completion Timeout Value in Blueprint

Babak, I'm not sure this will help, as the value I'm trying to replace is not an attribute, but a child element (see completionTimeout element below: aggregate aggregationRepositoryRef=aggregatorRepository strategyRef=postingRequestResultAggregationStrategy

Re: Property Placeholder for Aggregation Completion Timeout Value in Blueprint

Ah, but I see that I can use the completionTimeout as an attribute; I've tried it using the special namespace with 2.10.5 and it worked. Thanks! --sgp On Mon, Aug 19, 2013 at 1:32 PM, Scott Parkerson sc...@parkerson.netwrote: Babak, I'm not sure this will help, as the value I'm trying to

Re: Property Placeholder for Aggregation Completion Timeout Value in Blueprint

Also, for what it's worth, I can stay at the currently supported version of Camel we are using and do this: completionTimeout simple${properties:processor.posting.aggregation_timeout_millis}/simple /completionTimeout --sgp On Mon, Aug 19, 2013 at 1:39

Re: CookieStore

I dont think this is supported. Feel free to dive into to see what a solution could be. And if so log a JIRA and if possible provide a patch. We love contributions On Mon, Aug 19, 2013 at 4:56 PM, Markus Wolf markus.w...@sinnerschrader.com wrote: Hallo camel users, currently we use the

Nesting choices is broken!!

If I nest a CBR inside the when of an outer CBR where the outer when condition is true and the inner CBR does not match any when condition then the outer otherwise clause gets executed. Here is the simplest route example to show this that I can come up with: route from

Re: Nesting choices is broken!!

Here is the route with the formatting preserved. I realize in this case that the 2 choices could have been flattened into one, but I actually discovered this with the inner CBR inside a split! -- View this message in context:

Re: Conditional routing and local variables

On Mon, Aug 19, 2013 at 10:41 PM, peacock.snowdrift mark.har...@arcinnovations.co.nz wrote: Claus Ibsen-2 wrote A good idea is to check the docs http://camel.apache.org/predicate.html For example you can use the front page of Apache Camel http://camel.apache.org/ And type in

Re: AW: How to programatically add a route to ClassPathXmlApplicationContext?

thank you -- View this message in context: http://camel.465427.n5.nabble.com/How-to-programatically-add-a-route-to-ClassPathXmlApplicationContext-tp5737288p5737540.html Sent from the Camel - Users mailing list archive at Nabble.com.

Apply change to a route after loading camelcontext xml using GenericApplicationContext

Hi guys, I have a piece of code below. What I want to do is to load a camelcontext from a xml file by using GenericApplicationContext and XmlBeanDefinitionReader. Then I want to make some change on one route, for example, setting the autoStartup property to false. At last, start camelcontext using

Re: Conditional routing and local variables

pontus.ullgren wrote from(uri) ... stuff here... .to(destination) .choice() .when(constant(localVar).isEqualTo(value)).to(additionalDestination); Thank you. -- View this message in context: http://camel.465427.n5.nabble.com/Conditional-routing-and-local-variables-tp5737490p5737542.html

Re: Apply change to a route after loading camelcontext xml using GenericApplicationContext

You might want to stop the route first. On Mon, Aug 19, 2013 at 3:01 PM, bonnahu bonn...@gmail.com wrote: Hi guys, I have a piece of code below. What I want to do is to load a camelcontext from a xml file by using GenericApplicationContext and XmlBeanDefinitionReader. Then I want to make

Re: Apply change to a route after loading camelcontext xml using GenericApplicationContext

Hi Christian, Thanks for your response. However, I don't understand that why I need to stop the route first, since I haven't started the route yet until main.run(); Please explain it a little bit more. thanks -- View this message in context:

Getting a Header property on a exception in the DSL

Hello, I am trying to print the client id on a exception message like this: from(seda:AddDataToCache).routeId(AddDataToCache) .threads() .choice() .when(header(CamelJdbcRowCount).isEqualTo(0)) .log(No database record)