GenericFileMessage creates body from file multiples times

Hi all, using the file component I encountered a behaviour that doesn't seem right to me... but maybe it's an intended behaviour. Basically the issue shows when I have a route that reads the contents of a file using the file component and then the message body goes to null. At this point, any

Re: parallelProcessing with multicast

You need to be aware that multicast is sending a copy of the same incoming message. So the filter is either true or false for all the messages as they are from the same copy. So in one case they are all odd, and in another case they are all even. And then they process about the same time and the

Re: parallelProcessing with multicast

You need to enable streaming mode to have out of order aggregation - even for multicast. The work is done in parallel, but in non streaming mode the aggregation happens in fixed order. On Wed, Apr 1, 2015 at 1:52 PM, Christophe Pache chpa...@gmail.com wrote: Hello everyone I have tried to

Re: parallelProcessing with multicast

Thanks Claus for your answer! I did test but did not succeed into making it work as I wanted to (change the order of received message). Following your advice, I've just added the streaming configuration to the multicast eip such as following, is that correct? val croute = new

Apache Camel 2.15.1 released

The Camel community announces the immediate availability of the new patch release Camel 2.15.1. This release contains a total of 55 fixes applied in the few weeks by the community on the Camel master branch.    The artifacts are published and ready for you to download[1] either from the Apache

parallelProcessing with multicast

Hello everyone I have tried to test the parallel processing with Camel. The split was easy and worked out of the box. I have some surprises and I'm wondering whenever I'm understanding correctly the expected behaviour with the multicast. In the Code below, I try to send messages to two routes.

Re: parallelProcessing with multicast

An incident that is necessary to call a method .end() from(...) .filter() .to(myprocess) .to(mock.out) .end(); Your account is perceived as from(...) .filter() .to(myprocess) .end() .to(mock.out); -- View this message in context:

Re: parallelProcessing with multicast

Thanks, You are true. Sorry, I should have pasted the code where I send exchanges again. List(0, 1, 0, 1, 0, 1, 0, 1, 0, 1).foreach(x =sendBody(direct:input, x)) I'm sending 10 exchanges. I hope I'll receive 10 in the end and I'm not expecting aggregation in fact. I've controlled each sub

How to handle two dimensional arrays

Hi everyone, We have a Camel Processor which can return an Object[][], but how do one deal with the result if each of the Objects is a message you want to further handle downstream? Any help is greatly appreciated. Regards Divan Mostert | Head of iO Development C24.biz M: +264 81 383 2924

Re: parallelProcessing with multicast

Thanks, Alexey I added the end and then it worked. Well, Claus was true also: Now, I've understood the parallel processing is only on one exchange in one EIP at a time. My sample works, thanks guys!!! have a nice day Le 01. 04. 15 15:47, alexey-s [via Camel] a écrit : An incident that is

Errorhandler - Documentation Error?

Hi I have used following in my camel context camel:errorHandler id=deadLetterErrorHandler type=DeadLetterChannel deadLetterUri=log:dead camel:redeliveryPolicy maximumRedeliveries=2 redeliveryDelay=1000 logHandled=true asyncDelayedRedelivery=true handled=true/ /camel:errorHandler

camel-swagger in karaf? not yet....

With the release of 2.15.1 fixing a bug that prevented 2.15 from working in an OSGi environment, figured I'd give camel-swagger feature a try... 2015-04-01 09:52:38,672 | ERROR | qtp3964738-67| FeaturesPlugin | 88 - org.apache.karaf.webconsole.features - 3.0.3 | Can't

Marshal with quote in CSV

I'm creating csv file using Camel Bindy. using 2.12 version. In bindy model I have used @CsvRecord(separator = , , quote = \ ) when i open csv file values are coming without quotes but I need all the values with double quotes. ABC,TEST,CG,QEQE -- View this message in context:

Calling NTLM protected service from camel cxf component

Hi I am having trouble calling an NTLM protected service from my route. When my route sends data to endpoint rsClient below it looks as if the conduit config is not applied. I see the following in the logs: 20150401 10:21:18,929 EDT DEBUG http.HTTPConduit [Camel (camel) thread #0 - JmsConsumer

Re: camel-swagger in karaf? not yet....

Hi See the known issue section at http://camel.apache.org/camel-2150-release.html On Wed, Apr 1, 2015 at 4:24 PM, Ed Welch e...@edjusted.com wrote: With the release of 2.15.1 fixing a bug that prevented 2.15 from working in an OSGi environment, figured I'd give camel-swagger feature a try...

Re: camel-swagger in karaf? not yet....

And if I learn to search Jira properly, I find the issue now too :/ https://issues.apache.org/jira/browse/CAMEL-8568 Thanks Claus On Wed, 1 Apr 2015 16:42:40 +0200, Claus Ibsen claus.ib...@gmail.com wrote: Hi See the known issue section at http://camel.apache.org/camel-2150-release.html

Re: Errorhandler - Documentation Error?

Hi You have maybe mis-read the page, there is no handled=true on that page However there is a logHandled=true On Wed, Apr 1, 2015 at 4:05 PM, contactreji contactr...@gmail.com wrote: Hi I have used following in my camel context camel:errorHandler id=deadLetterErrorHandler

Problem Adding ActiveMQ Broker URL to Camel Context Using Java DSL Type Project

I'm trying to add the correct tcp:// connection url to the camel context in a standalone/Java DSL camel app and am using a boot() method that was pulled from example code on the camel site. In my boot() method I'm trying to add the correct URL to the camel context but it's not getting added.

Apache Camel-Mina2 ExchangePattern

I am trying to build a prototype using Apache Camel-Mina2 component. We have our own protocol implementation on TCP and I need to intercept Client - Server messages using a proxy Component. Existing - TCP Client TCP Server New - TCP Client Proxy Server - TCP Server One of the issue

Re: Apache Camel-Mina2 ExchangePattern

Current Camel-Mina2 producer just wait for the response when the endpoint sync option is true, it doesn’t support to set the reply mode dynamically. BTW, can you tell if Message exchange pattern by just looking up the message content? -- Willem Jiang Red Hat, Inc. Web:

Re: Problem Adding ActiveMQ Broker URL to Camel Context Using Java DSL Type Project

Hi, You should call the bind method instead of main.getOrCreateCamelContext() to add the configured the ActiveMQComponent like this. main.bind(  activemq,  amq.activeMQComponent(tcp://ourbrokerserver.workplace.com:61616));  main.getOrCreateCamelContext() just create a new camel map per call. 

Re: Apache Camel-Mina2 ExchangePattern

Hi Willem, Thanks for your response. I can check the message body for the two command headers that just need to be written out but not expect a reply. I think the underlying implementation for Mina2Producer will block my use case. I cannot do sync=false and with sync=true the Mina2Producer

Re: camel-swagger in karaf? not yet....

Ok, I've spent the bulk of my day on this, and have met with some success. There are a few other gotcha's trying to get swagger to run from karaf. (some issues were fought based on my application, for example, i was using guava 18, however swagger brings with it guava 15 creating some

kafka producer - multiple brokers

Please excuse my lack of experience with Kafka, but I understood that for redundancy purposes, a cluster would generally contain multiple brokers and that a producer woudl try to connect to any of a list of them. If that's true, how might I tell Camel about the availability of multiple brokers. I

Re: Calling NTLM protected service from camel cxf component

of? Is this user (who started the app) domain user? Hi I am having trouble calling an NTLM protected service from my route. When my route sends data to endpoint rsClient below it looks as if the conduit config is not applied. I see the following in the logs: 20150401 10:21:18,929 EDT

Re: Calling NTLM protected service from camel cxf component

Hi Surgey Thanks for the response. I am running on a tomcat instance on a linux server. The user is a windows user which is setup on our Windows Domain controller. I did try updating the http:authorization (within the http:conduit) element to include an AuthorizationType: