Re: Camel route exchange intermediate call

2013-12-11 Thread sdelanghe
Thanks for your feedback. It looked like i do not know my patterns to well ;-) I simply had to use the enrich pattern and combine back my original and resource exchange. Thanks for the feedback -- View this message in context:

Inject an endpoint into my route for testing purposes

2013-12-11 Thread richie.rivi...@gmail.com
Hi, Sorry to ask a few questions. I know i have asked a few recently. I have been looking up bean and endpoint injection today but can't find a blurb on my scenario. I have a route which uses a file component as the from endpoint... from(file:{{dir.item.inbox}}?

Re: Can useAdviceWith raise problems with errorhandling?

2013-12-11 Thread Stephan Burkard
OK, I add some probably helpful details I found out about this: - If I just remove the isUseAdviceWith() method that returns true, to inform Camel about my Advices, the test runs fine. - If I left the isUseAdviceWith() method in place and just start the Camel context before doing the route

building camel : disable camel-manual

2013-12-11 Thread lb
Hi, I'm trying to build camel behind a corporate firewall and the build fails for camel-manual: [INFO] --- exec-maven-plugin:1.2.1:java (generate-manual) @ camel-manual --- java.net.ConnectException: Connection timed out: connect at

Re: Inject an endpoint into my route for testing purposes

2013-12-11 Thread Stephan Burkard
Hi You can use the advice-functionality = http://camel.apache.org/advicewith.html Since Camel 2.9 you can (in the test) completely replace your From-Endpoint with replaceFromWith. Regards Stephan On Wed, Dec 11, 2013 at 12:30 PM, richie.rivi...@gmail.com richie.rivi...@gmail.com wrote:

Re: Problem with exception handler (onException) on Camel 2.12.X routes.

2013-12-11 Thread jguerra
I posted to you both a copy of the whole camel.xml. It's a working copy on Camel 2.7.0, but for some reason I got the problems described above on Camel 2.12.1. Please feel free to contact me to get more information -- View this message in context:

Implement readLock with lsof

2013-12-11 Thread Martín Steffen
Hello, I have a problem with the change readLock strategy when I send a file through FTP, When I send a file through FTP and occur network issues (package delay, lost, etc), then Camel takes an incomplete file due to expiration of readLockCheckInterval. Are you evaluated the option of use the

loggingErrorHandler formatting

2013-12-11 Thread Marco Crivellaro
how do I define the log format when using loggingErrorHandler? I am interested in setting properties like: showExchangeId, showExchangePattern, showBody... the default format is too verbose -- View this message in context:

DefaultCxfRsBinding only uses Exchange.getOut()

2013-12-11 Thread Dominik Amon
Hi, I currently stumbled upon an issue when using camel cxfrs component. Where I only get response code 204 - No Content when the route has a doTry block. I am using Camel 2.12.2 and Blueprint. The route is like: route id=myRoute from uri=cxfrs://bean://serviceBean/ doTry to

Re: DefaultCxfRsBinding only uses Exchange.getOut()

2013-12-11 Thread Sergey Beryozkin
Hi, On 11/12/13 15:26, Dominik Amon wrote: Hi, I currently stumbled upon an issue when using camel cxfrs component. Where I only get response code 204 - No Content when the route has a doTry block. I am using Camel 2.12.2 and Blueprint. The route is like: route id=myRoute from

Re: DefaultCxfRsBinding only uses Exchange.getOut()

2013-12-11 Thread Dominik Amon
Hello Sergey I debugged a bit further into camel and found out that the TryProcessor calls ExchangeHelper.prepareOutToIn(exchange) so at the time of populating the CxfRSResponse from the the exchange the Out is always null in my case. When I remove the the doTry and doFinally I get a response,

Re: Problem with exception handler (onException) on Camel 2.12.X routes.

2013-12-11 Thread kraythe .
I suspect you have two exceptions propagating. One occurs in the main body of your route. This causes the onException block to trigger but immediately its bringing up the second exception when trying to process the telemetryFailureProcessor. The second is causing the the onException block to

Re: Understanding ActiveMQ consumer with concurrentConsumers

2013-12-11 Thread kraythe .
Each of the consumer routes is brought up concurrently on different threads. They will suck in messages as fast as they can, competing like kids for candy tossed on the middle of a floor. So while thread 1 is waiting 5 seconds, threads 2, 3, 4, 5, ... and so on aren't and grabbing the next message

Re: Inject an endpoint into my route for testing purposes

2013-12-11 Thread kraythe .
Try : http://camel.apache.org/advicewith.html *Robert Simmons Jr. MSc. - Lead Java Architect @ EA* *Author of: Hardcore Java (2003) and Maintainable Java (2012)* *LinkedIn: **http://www.linkedin.com/pub/robert-simmons/40/852/a39 http://www.linkedin.com/pub/robert-simmons/40/852/a39* On Wed,

Re: Implement readLock with lsof

2013-12-11 Thread kraythe .
try: from(file:/mypath?include=.*\\.xlsxreadLock=changeddelay= + this.config .fileReadDelay()+ moveFailed=Errorsmove=Processed) This sets up a locking strategey delay that will fail to get the read lock if the file has been changed within fileReadDelay() milliseconds. When the file is streaming

Re: Inject an endpoint into my route for testing purposes

2013-12-11 Thread kraythe .
Damn stephan you beat me to it. :) *Robert Simmons Jr. MSc. - Lead Java Architect @ EA* *Author of: Hardcore Java (2003) and Maintainable Java (2012)* *LinkedIn: **http://www.linkedin.com/pub/robert-simmons/40/852/a39 http://www.linkedin.com/pub/robert-simmons/40/852/a39* On Wed, Dec 11, 2013

Re: Apache Camel File component preMove, move and moveFailed relative rather than absolute

2013-12-11 Thread kraythe .
Its working according to the documentation. try ../done to make done a sibling to staging. *Robert Simmons Jr. MSc. - Lead Java Architect @ EA* *Author of: Hardcore Java (2003) and Maintainable Java (2012)* *LinkedIn: **http://www.linkedin.com/pub/robert-simmons/40/852/a39

Re: DefaultCxfRsBinding only uses Exchange.getOut()

2013-12-11 Thread Sergey Beryozkin
Hi Dominik Sure, thanks for the clarifications. Please open a JIRA and attach your patch there, I can do it on your behalf but I guess it would be better for the actual contributor to do it.nding In meantime, let me ask few more questions: On 11/12/13 15:53, Dominik Amon wrote: Hello Sergey

Re: Understanding ActiveMQ consumer with concurrentConsumers

2013-12-11 Thread dimitry12
I tested this morning and can confirm: it was a prefetch-related issue. I modified the route as: from uri=activemq://item_updates?concurrentConsumers=20amp;destination.consumer.prefetchSize=1 / delayconstant5000/constant/delay log message=item ${header.item_id} / and now each of 20 concurrent

How to get user in camel processor? (Spring security on REST Service + CXFRS Component)

2013-12-11 Thread M314
I use Spring security to protect access to rest service on server. Application use Camel framework to handle request/messages. So when request pass though spring security, then camel transform it to the Exchange class (I'm using CXFRS Component for that), and further processing is prepared by

Re: DefaultCxfRsBinding only uses Exchange.getOut()

2013-12-11 Thread Dominik Amon
Hi Sergey, i created a JIRA ( https://issues.apache.org/jira/browse/CAMEL-7061 https://issues.apache.org/jira/browse/CAMEL-7061 ). Sergey Beryozkin-3 wrote What I'm not understanding yet is what kind of response you actually get if IN message is checked ? The problem in my case is that

Re: How to get user in camel processor? (Spring security on REST Service + CXFRS Component)

2013-12-11 Thread Sergey Beryozkin
Hi On 11/12/13 16:56, M314 wrote: I use Spring security to protect access to rest service on server. Application use Camel framework to handle request/messages. So when request pass though spring security, then camel transform it to the Exchange class (I'm using CXFRS Component for that), and

Re: Understanding ActiveMQ consumer with concurrentConsumers

2013-12-11 Thread dimitry12
@kraythe: Yes, you described what I was expecting: every consumer getting its own message and processing it simultaneously. What I was getting: one consumer prefetching all messages in the queue and processing them sequentially, while all other consumers were sitting and doing nothing. -- View

Re: Implement readLock with lsof

2013-12-11 Thread Martín Steffen
Hi, Thanks for your answer. But, in your scenario, a file that is uploaded needs to wait 5 minutes to be taked by Camel? If NOT exists network issues, the file takes 5 minutes to be taked by Camel? This is unacceptable for me. Thanks, Martin. On 12/11/13 2:08 PM, kraythe . kray...@gmail.com

Re: Problem with exception handler (onException) on Camel 2.12.X routes.

2013-12-11 Thread jguerra
Yes, you are right as far I can see. it's correct that there is a double exception inside of the telemetryFailureProcessor when the message is not valid **but** when the message is valid, the exception still comes up!. Even though the processor is removed from the route, the java.sql.SQLException

Re: DefaultCxfRsBinding only uses Exchange.getOut()

2013-12-11 Thread Sergey Beryozkin
Hi On 11/12/13 17:02, Dominik Amon wrote: Hi Sergey, i created a JIRA ( https://issues.apache.org/jira/browse/CAMEL-7061 https://issues.apache.org/jira/browse/CAMEL-7061 ). Thanks Sergey Beryozkin-3 wrote What I'm not understanding yet is what kind of response you actually get if IN

Header/Property stay between requests

2013-12-11 Thread horyna
Hi, using Camel 2.12 i have a route with start: .setHeader(RESPONSE_LIST_KEY, constant(new ArrayListValidateProductActivationResponse())) and inside adding some ValidateProductActivationResponse objects into the List. Problem is, that this header object (RESPONSE_LIST_KEY) is persist over

Re: Header/Property stay between requests

2013-12-11 Thread Claus Ibsen
The constant is a constant, and only created every once. Use a method call to create a new instance, such as: .setHeader(foo, method(MyBean.class, createNewList)) And have a public method that create that new list you want. On Wed, Dec 11, 2013 at 7:58 PM, horyna phoffic...@centrum.cz

Re: Email Alerts Upon FTP Failure

2013-12-11 Thread funkymonk
I apologize. I'm completely lost by this. I've been given a Windows machine with apache servicemix installed, and I have several sFTP routes working using the blueprint XML template. I'm struggling with the Camel documentation because it never seems to resemble anything that I am currently

Re: Problem with AWS-Component = accessKey + secretKey Parameters not working

2013-12-11 Thread ads_green
Following on from this original issue. With Camel 2.12.2. If you have a url route defined as aws-sqs://Queue?accessKey=xxxsecretKey=yyy And yyy contains an embedded +. If you encode this using a %2B then Camel will double decode this value during route setup if using the DefaultCamelContext.

Re: building camel : disable camel-manual

2013-12-11 Thread Christian Müller
You can also consider to configure your Maven proxy settings... Best, Am 11.12.2013 12:50 schrieb lb lburgazz...@gmail.com: Hi, I'm trying to build camel behind a corporate firewall and the build fails for camel-manual: [INFO] --- exec-maven-plugin:1.2.1:java (generate-manual) @

Re: Problem with AWS-Component = accessKey + secretKey Parameters not working

2013-12-11 Thread Claus Ibsen
You can use the raw options as documented here http://camel.apache.org/how-do-i-configure-endpoints.html On Wed, Dec 11, 2013 at 9:31 PM, ads_green ads_gr...@hotmail.com wrote: Following on from this original issue. With Camel 2.12.2. If you have a url route defined as

Re: Email Alerts Upon FTP Failure

2013-12-11 Thread Claus Ibsen
Hi I think Rejl mixed up Apache ServiceMix with another product called JBoss Fuse. http://www.jboss.org/products/fuse The latter has a number of examples out of the box in the examples directory, such as the cbr which Rejl referred too. Apache ServiceMix has a different set of examples it

Re: Implement readLock with lsof

2013-12-11 Thread Claus Ibsen
Hi Then you can implement your custom read lock strategy where you can use any java code to do whatever you want. On Wed, Dec 11, 2013 at 6:14 PM, Martín Steffen mstef...@3cinteractive.com wrote: Hi, Thanks for your answer. But, in your scenario, a file that is uploaded needs to wait 5

Re: loggingErrorHandler formatting

2013-12-11 Thread Claus Ibsen
You cannot customize the logging. Instead use dead letter channel and use a log endpoint as its endpoint. Then you can configure what to show on the log endpoint. http://camel.apache.org/log On Wed, Dec 11, 2013 at 2:37 PM, Marco Crivellaro marco.cr...@gmail.com wrote: how do I define the log

Re: Does resequencer add any headers to echange?

2013-12-11 Thread Claus Ibsen
On Fri, Dec 6, 2013 at 10:39 AM, talk2patel86 dharmendra.k.pa...@gmail.com wrote: Does resequencer add any headers to incomming echange to indicate timed out resequencing? No from the code I cannot see we add any header to indicate it was due the batch timeout. -- View this message in

Re: Email Alerts Upon FTP Failure

2013-12-11 Thread funkymonk
Ok great, thank you very much. I think I found the Blueprint Example. My existing routes only have the blueprint and camelContext tags in them. So if I want to receive an email when the FTP transaction in my route fails, I will need to add a bean component and reference that bean in the route?

JPA @Consumed

2013-12-11 Thread richie.rivi...@gmail.com
Hi guys, I have a route which selects from the database using a JPA entity bean. I then do some processing on the bean in the route and would like to mark the bean as processed when the route is complete. Seems like a pretty typical scenario for me to use @Consumed in my entity bean. The select

Re: JPA @Consumed

2013-12-11 Thread richie.rivi...@gmail.com
I just had a thought whilst walking my dog. In the past when I have got JPA updating the database it has been in a TypeConverter class and what I had to do was . JpaTemplate template = exchange.getIn().getHeader(CamelConstants.HEADER_KEY_JPA_TEMPLATE, JpaTemplate.class);

It should be document issue

2013-12-11 Thread xielei
Quartz2 Component http://camel.apache.org/quartz2.html Configuring quartz.properties file section bean id=quartz class=org.apache.camel.component.quartz2.QuartzComponent property name=propertiesFile value=com/mycompany/myquartz.properties/ /bean The bean id shoud be quartz2 ! -- View

Re: It should be document issue

2013-12-11 Thread Willem Jiang
Thanks for point that out, I just updated the wiki page for it. -- Willem Jiang Red Hat, Inc. Web: http://www.redhat.com Blog: http://willemjiang.blogspot.com(http://willemjiang.blogspot.com/) (English) http://jnn.iteye.com(http://jnn.javaeye.com/) (Chinese) Twitter: willemjiang Weibo:

Re: JPA @Consumed

2013-12-11 Thread Willem Jiang
Can you change the below to(“jpa…”) to pollEnrich(“jpa…”)? In this way the @Cousumed can be called. -- Willem Jiang Red Hat, Inc. Web: http://www.redhat.com Blog: http://willemjiang.blogspot.com(http://willemjiang.blogspot.com/) (English) http://jnn.iteye.com(http://jnn.javaeye.com/)

Re: JPA @Consumed

2013-12-11 Thread richie.rivi...@gmail.com
Thanks Williem, Changing my route to ... .pollEnrich(jpa://org.apache.camel.auski.etl.entity.ImportPayloadEntity?consumer.namedQuery=queryImportPayloadsconsumeDelete=falsedelay=3000consumeLockEntity=false) worked!!! But still a bit of a problem.. The ImportPayloadEntity contains a list of

Re: building camel : disable camel-manual

2013-12-11 Thread Willem Jiang
We have some trouble when doing the release if enable the camel-manual module with profile.  I’m not sure if we have time to revisit it again.  -- Willem Jiang Red Hat, Inc. Web: http://www.redhat.com Blog: http://willemjiang.blogspot.com(http://willemjiang.blogspot.com/) (English)

Archive files using apache camel

2013-12-11 Thread Claire
Hi, I wonder if there is a way to do archive files in camel. Once I translated from my csv file into xml file, there will be many xml file. What I would like to do is to do archive files (number of files to be archived would depends on properties file). Thank you much in advance. -- View this

Re: JPA @Consumed

2013-12-11 Thread richie.rivi...@gmail.com
Maybe the pattern is to just have ImportPayloadEntity @Consumed loop through it's collection of ItemEntity classes and mark them all as processed. I just tried this and it worked (although I'm not sure it's the right pattern). thanks -- View this message in context:

Re: JPA @Consumed

2013-12-11 Thread richie.rivi...@gmail.com
Abother question about @Consumed. Using the strategy as described in my last post, what I am doing in selecting an ImportPayloadEntity, splitting this entity which has a list of ItemEntities into individual ItemEntity objects and processing each ItemEntity object. During the processing of each

Re: building camel : disable camel-manual

2013-12-11 Thread lb
Proxy is properly configured and dependencies are downloaded without problems. The only issue is with camel-manual. — lb On Wed, Dec 11, 2013 at 10:05 PM, Christian Müller christian.muel...@gmail.com wrote: You can also consider to configure your Maven proxy settings... Best, Am 11.12.2013

Reading file using camel

2013-12-11 Thread Claire
Hi, I have two files to convert from csv file to xml file and I also have another file (properties or excel file) to lookup. So I would like to read value from that excel file and convert my csv to xml file based on those values. I did one java to read those value from that lookup table file but