Re: A basic query with using Direct Component

I am not sure, maybe try setting the openedSuffix to an empty string to see if that works? On Thu, Jun 19, 2014 at 8:39 AM, Chirag Dewan wrote: > Hi Claus, > > Thanks for response. > > I am using Camel 2.12.1 with camel-hdfs 2. > > Yes,that is the problem. Write operation fails and .opened file i

Re: A basic query with using Direct Component

Hi Claus, Thanks for response. I am using Camel 2.12.1 with camel-hdfs 2. Yes,that is the problem. Write operation fails and .opened file is still there on HDFS. Is there any option through which I can skip creating .opened file? Chirag From: Claus

Re: Consuming messages from multiple AMQ queues and forward it to single AMQ queue concern

Thanks Claus , this is very helpful and rock! - Othman Darwish ProgressSoft Corp. -- View this message in context: http://camel.465427.n5.nabble.com/Consuming-messages-from-multiple-AMQ-queues-and-forward-it-to-single-AMQ-queue-concern-tp5752514p5752550.html Sent from the Camel - Users ma

Re: File aggregation

Hi Claus Ibsen I think I kept my point wrongly . Here I don't know the count how many I will receive. In that scenario also can I aggregate. -- View this message in context: http://camel.465427.n5.nabble.com/File-aggregation-tp5752538p5752549.html Sent from the Camel - Users mailing list archiv

Re: File aggregation

Hi There is the aggregate eip http://camel.apache.org/aggregator2 On Thu, Jun 19, 2014 at 7:26 AM, sakchakravarthi wrote: > Hi > I have a scenario that I need to take list of json files from a file > location which are related to one category. So I need to process 10 files in > one transaction.

Re: Consuming messages from multiple AMQ queues and forward it to single AMQ queue concern

Hi There is also message groups that can allow FIFO for a group of messages while allow parallel processing of multiple groups. http://activemq.apache.org/message-groups.html On Thu, Jun 19, 2014 at 8:05 AM, Darwish wrote: > Thanks kraythe for reply ...appreciate it > > The ordering is crucial

Re: Consuming messages from multiple AMQ queues and forward it to single AMQ queue concern

Thanks kraythe for reply ...appreciate it The ordering is crucial for sub-set of those messages to be serve in FIFO since its have impact on my business which may lead to "business" dead lock if it not processed in the FIFS maaner . for example imagine that message A which will debit custom

File aggregation

Hi I have a scenario that I need to take list of json files from a file location which are related to one category. So I need to process 10 files in one transaction. Now how can I aggregate files when I don't know number of file I received. Could any one help me on this? -- View this message in

Re: A basic query with using Direct Component

On Thu, Jun 19, 2014 at 7:11 AM, Chirag Dewan wrote: > Hi All, > > I have a route with direct as following : > > from("direct:abc").to("hdfs2:x?splitStrategy=MESSAGE"); > > I use the route write files in HDFS. I use the producer template to send a > OutputStream to direct: > > producerTemplat

A basic query with using Direct Component

Hi All, I have a route with direct as following : from("direct:abc").to("hdfs2:x?splitStrategy=MESSAGE"); I use the route write files in HDFS. I use the producer template to send a OutputStream to direct: producerTemplate,sendBody("direct:abc",OutputStream); Now HDFS producer creates an .

Re: How to use a public endpoint outside of camecontext?

What kind of exception did you get?  Even the camel context is created by akka, you already setup the Registry for camel context to look up. You can also try to specify the full uri if the endpoint look up doesn’t work. -- Willem Jiang Red Hat, Inc. Web: http://www.redhat.com Blog: http://w

Re: split with bean: multithreading problem

As Camel create the bean instance when it setup the method expression so your bean method should be stateless. Please store the context information into the message header or exchange property. -- Willem Jiang Red Hat, Inc. Web: http://www.redhat.com Blog: http://willemjiang.blogspot.com (Eng

Re: can't I use spel in camel-quartz2

Sorry for the mess. I was trying to use Spring pattern, but after I've read the http://camel.apache.org/properties.html I realized I should use {{ prefix and }} sufix pattern. Alessandro -- View this message in context: http://camel.465427.n5.nabble.com/can-t-I-use-spel-in-camel-quartz2-tp575

Re: Camel Bindy problem with separator

An unit test case could be helpful for us the dig the issue. -- Willem Jiang Red Hat, Inc. Web: http://www.redhat.com Blog: http://willemjiang.blogspot.com (English) http://jnn.iteye.com (Chinese) Twitter: willemjiang Weibo: 姜宁willem On June 18, 2014 at 9:19:05 PM, Darwish (othman.darw...

Re: Unable to get response from rest service

It may relates to camel stream caching[1]. Can I have a look at your route? [1]http://camel.apache.org/stream-caching.html -- Willem Jiang Red Hat, Inc. Web: http://www.redhat.com Blog: http://willemjiang.blogspot.com (English) http://jnn.iteye.com (Chinese) Twitter: willemjiang Weibo: 姜宁wil

Re: can't I use spel in camel-quartz2

camel-quartz only supports cron expression, so you cannot use spel there. I’m not sure if the property support could help you, you can use camel-properties[1] inside of cron expression. [1]http://camel.apache.org/properties -- Willem Jiang Red Hat, Inc. Web: http://www.redhat.com Blog: http:/

can't I use spel in camel-quartz2

Hi guys, Is there a way to use spel in camel-quartz2 to define the cron expression? Thanks Alessandro -- View this message in context: http://camel.465427.n5.nabble.com/can-t-I-use-spel-in-camel-quartz2-tp5752521.html Sent from the Camel - Users mailing list archive at Nabble.com.

Re: Best suitable architecture using Camel

Thank you for your timely and thoughtful response Christian. I'd love to be at your presentation - as I've been aware of your involvement with camel for years - and know your contributions are significant. But alas, I'll be at my desk working. I think the important thing I'm taking away from

Re: Consuming messages from multiple AMQ queues and forward it to single AMQ queue concern

Enforcing order in synch programming is not an easy order. Why do they have to be consumed in a particular order? There are ways to handle such things but they won't be simple. Different queues behave at different speeds potentially. I think I would need more information to suggest a strategy. For

Re: Mocking predicate in existing camel route

Claus Ibsen-2 wrote > Hi > > You cannot advice the predicates inside the eips such as the CBR. You > can instead replace the entire CBR with your own which you can provide > in the route builder. I'm afraid this solution is not acceptable, because in that case i won't be able to add a new process

Re: Best suitable architecture using Camel

Do Camel components save you time? Does Camel encourage you to build software in a way that might be constraining but also might have some wisdom behind it? For example, do all Camel programs feel familiar? You can only decide by riding Camel around for a while. Is Camel better than writing tradi

Re: Best suitable architecture using Camel

Unfortunately I do not have good examples for this. My own examples are too small to make good business cases and the customer projects I work in are not open source. Maybe I got something more after apachecon. I submitted a talk about lessons learned from customer projects in the OSGi environme

Consuming messages from multiple AMQ queues and forward it to single AMQ queue concern

Hi , I have a requirement where the processing of messages in FIFO produced from multiple AMQ queues is critical , optionally those messages may be forward to a single dedicated queue "X" after some business rules evaluation . My concern is :if I build multiple routes to consumes message

Intercept - Log Message EIP for testing

Hello All, I am writing a Camel Context test and I want to intercept a logging endpoint to verify that a message is being logged. Here is a snippet from my route:

Re: Mocking predicate in existing camel route

Hi You cannot advice the predicates inside the eips such as the CBR. You can instead replace the entire CBR with your own which you can provide in the route builder. On Wed, Jun 18, 2014 at 11:58 AM, ascetic wrote: > Hello. I have a route > > from("direct:slr").routeId("slr") >

Re: camel mail: content-transfer-encoding configurable

Hi You are welcome. We love contributions. http://camel.apache.org/support If you could make this optional, so you need to turn this on so it wont affect existing users. Then that would be the best imho. On Wed, Jun 18, 2014 at 3:15 PM, cgiera wrote: > Hello, > > the camel mail componente dete

Re: Notifier when FTP Polling starts to read a file

The consumer creates the exchange so its the created event instead. On Wed, Jun 18, 2014 at 4:39 PM, Chubutin wrote: > Hi! I'm trying to audit a route which starts with *from("ftp:*)*. The > objetive is to log (in another class) when the FTP Consumer detect a file > and the consumer start to pr

Notifier when FTP Polling starts to read a file

Hi! I'm trying to audit a route which starts with *from("ftp:*)*. The objetive is to log (in another class) when the FTP Consumer detect a file and the consumer start to process the FIle (move or delete, or anything). My first approach is to create a Notifier and process the exchanges, but i don't

Re: Why do I get so many "external redeliveries" when using Camel with JMS topics?

Same JVM, different connection factory. Do I need to explicitly set the clientId on each connectionFactory? This is what I have: Thanks, Jeff On 6/17/14 7:33 PM, "Minh Tran" wrote: >Is your non-camel subscriber running

Unable to get response from rest service

Hi All I am getting veered problem. I have a route with rest client which provide me with json. I am able to get json when I hit web service from browser. But through application It was not picked up. Just as hit or trail to see debug logs I changed my log level in log4j.xml from TRACE to DEBUG,

Re: Camel Bindy problem with separator

Hi , I am using 2.11.0 and suffering the same problem Any Updates ? - Othman Darwish ProgressSoft Corp. -- View this message in context: http://camel.465427.n5.nabble.com/Camel-Bindy-problem-with-separator-tp4306927p5752503.html Sent from the Camel - Users mailing list archive at Nabb

camel mail: content-transfer-encoding configurable

Hello, the camel mail componente determines the content-transfer-encoding itself based on the content of the message. We now have a customer we are only allowed to send messages where the content-transfer-encoding is base64. As most of the messages haven't any special characters camel determines 7

Re: split with bean: multithreading problem

The problem occures in camel 2.11.0 and 2.13.0. kind regards, Christoph -- View this message in context: http://camel.465427.n5.nabble.com/split-with-bean-multithreading-problem-tp5752258p5752502.html Sent from the Camel - Users mailing list archive at Nabble.com.

Re: nested catch-blocks in doCatch and doFinally

thanks for replying, Willem. I've tried that workaround before and it works. -- View this message in context: http://camel.465427.n5.nabble.com/nested-catch-blocks-in-doCatch-and-doFinally-tp5752429p5752498.html Sent from the Camel - Users mailing list archive at Nabble.com.

Mocking predicate in existing camel route

Hello. I have a route from("direct:slr").routeId("slr") .choice() .when(slrBookPredicate()).id("slrBookPredicate") .process(slrDBLogger()).id("slrDBLogger") .beanRef("jmsSlrLogg

RE: JPA entityType always Null

There's a camel-jpa's own unit-test verifiying that the @Consumed annotated method below: https://github.com/apache/camel/blob/master/components/camel-jpa/src/test/java/org/apache/camel/examples/MultiSteps.java#L81 is properly invoked (step is increased from 1 to 2): https://github.com/apache/came

How to mock rabbitmq endpoints?

I'm working on my testing my CamelContext Routes. I am using a SpringJunit4ClassRunner to run my tests and start my CamelContext (defined in Spring XML). I have the*@MockEndpoints* annotation set at the class-level. How do I reference the mocked equivalents of my RabbitMQ endpoints? For instance

How to mock a predicate in existing route?

Hello. I have a route from("direct:slr").routeId("slr") .choice() .when(slrBookPredicate()).id("slrBookPredicate") .process(slrDBLogger()).id("slrDBLogger") .beanRef("jmsSlrLogger",

Re: nested catch-blocks in doCatch and doFinally

There are two doTry blocks in your camel route which could confuse the compiler, as Camel Java DSL is not good at blocks. You can work around the issue by using the direct endpoint to avoid using doTry inside of doCatch just like this             from("direct:start")                     .doTry()

Re: Disable auto redirect

I just wrote a simple unit test[1] to verify the issue that you find, the test passed in camel master branch. [1]http://git-wip-us.apache.org/repos/asf/camel/diff/b6a87991 -- Willem Jiang Red Hat, Inc. Web: http://www.redhat.com Blog: http://willemjiang.blogspot.com (English) http://jnn.iteye