AW: Camel-CXF: Problems transforming namespace of incoming message

2015-01-20 Thread Dirk Lattermann - expertplace
Hi, thanks for your answer! The intention is different: Working routing is: from CXF-B(1) --> (if ..some condition..) --> to CXF-B(2) on different host additional, a namespace mapping is needed: from CXF-A --> namespace mapping A to B --> to CXF-B(1) so that above route is taken the "

FTP2 Component. Is there any way to SFTP the file from one endpoint to Other based on the file name which is received as message from Producer Route

2015-01-20 Thread V4Vaithi
My Requirement is to SFTP the file from one end point to other endpoint when i receive a filename in a message from Queue. I have implemented Polling consumer to do this through processor. But problem is my Route is blocked if the specified file is not available in path. i used consumer.receive(

Choosing between Mapping Options

2015-01-20 Thread Satyam Maloo
We have a camel project requirement where 5 SOAP based CXF services needs to interact with each other. Among these 2 camel projects are consumer and 3 cxf providers. The integration framework used is JBoss Fuse ESB. At the Integration layer we have created a common canonical format xsd. Now we ne

How to avoid continuous retry attempts to stop the route when there is problem with Producer Endpoint

2015-01-20 Thread V4Vaithi
I have a sample route which has MQ as producer endpoint and consumer as logger endpoint. If there is any problem in connecting to Producer endpoint. Camel continuously retries to start the route. How to avoid camel from retrying continuously? Sample Route Configuration.

Re: Apache Camel access a Spring Bean which invokes a Stored Procedure , Below is a Screenshot of SpringXML-Config file that hits a Stored Procedure successfully and display results.What would be the

2015-01-20 Thread Claus Straube
Have a look at this: http://camel.apache.org/bean.html ... .to("bean:customerDataService") ... On Tue, Jan 20, 2015 at 8:03 PM, Vishnu Kumar wrote: > > > > > -- > View this message in context: > http://camel.465427.n5.nabble.com/Apac

Apache Camel access a Spring Bean which invokes a Stored Procedure , Below is a Screenshot of SpringXML-Config file that hits a Stored Procedure successfully and display results.What would be the best

2015-01-20 Thread Vishnu Kumar
-- View this message in context: http://camel.465427.n5.nabble.com/Apache-Camel-access-a-Spring-Bean-which-invokes-a-Stored-Procedure-Below-is-a-Screenshot-of-SpringXMl-tp5761959.html Sent from the Camel - Users mailing list archive

RE: Input directory with multiple file consumers

2015-01-20 Thread Kondalarv
I tried below option and it is working http://camel.465427.n5.nabble.com/Input-directory-with-multiple-file-consumers-tp5713788p5761967.html Sent from the Camel - Users mailing list archive at Nabble.com.

Re: sftp and path

2015-01-20 Thread sreejeb2
Hi Abhaiji, I'm facing the same issue as you explained. Did you get a solution for your problem. Changing stepwise to true/false is not working for me too. Here is my endpoint ftp://sftpUserName@sftpServer/sftpUploadFolder?password=sftpPassword&disconnect=true&binary=true&throwExceptionOnConnectFa

mvn clean install -Pvalidate

2015-01-20 Thread shreyas
Hello, When I run 'mvn clean install -Pvalidate' command on master in platforms directory, it fails with below message (No connector available to access repository google.script.repo (htt p://scriptengines.googlecode.com/svn/m2-repo/) of type default using the available factories WagonRepositor

Messages sitting on ActiveMq for x period of time

2015-01-20 Thread mvandersteen
Hi Guys, I have 1 queue created through camel that holds onto messages for approx 15 minute before a consumer will pick them up. A cxf web service listens for incoming message as SOAP, then pushes translated message to said queue. That message will sit there for approx 15 minutes before another

Re: File Competing Consumers

2015-01-20 Thread Kondalarv
I don't find any example code on this. Can you please provide me a sample ? -- View this message in context: http://camel.465427.n5.nabble.com/File-Competing-Consumers-tp5714255p5761968.html Sent from the Camel - Users mailing list archive at Nabble.com.

SFTP exclude un-readable directory

2015-01-20 Thread shreyas
Hello, I am using the SFTP component to recursively scan directories to read files. The server creates some unix "lost+found" directories with root permission. I want to exclude scanning this directory as it results in permission errors. I have tried: antExclude=**/lost+found/**  ignoreFileNotF

Re: CXFRS component to expose Rest apis

2015-01-20 Thread Sergey Beryozkin
Hi On 20/01/15 18:37, cgsk wrote: Hi There, I have a requirement to expose few 10s of Rest based endpoints in camel. I am using cxfrs component. Is it recommended to have multiple instance of cxf:rsServer defined in the camel context for various service operations? Or is there a way to overcome

Re: How to handle requests sequentially for a given item

2015-01-20 Thread arthurs
We're already using activemq as our incoming destination. The issue is that we also set concurrentConsumers > 1 and asyncConsumer=true. Would Message groups still work? Or do we need to set asyncConsumer=false? -- View this message in context: http://camel.465427.n5.nabble.com/How-to-handle-

Issue setting property on the object which in the exchange body

2015-01-20 Thread gilboy
Hi In my route, I have a header property on the exchange called age. In the body of the exchange I have a person object. I want to set the age property on the person object. If I do something like the following in my route and have the setAge property on the Person bean use the header annotation

CXFRS component to expose Rest apis

2015-01-20 Thread cgsk
Hi There, I have a requirement to expose few 10s of Rest based endpoints in camel. I am using cxfrs component. Is it recommended to have multiple instance of cxf:rsServer defined in the camel context for various service operations? Or is there a way to overcome from defining multiple cxf:rsServer?

Re: How to handle requests sequentially for a given item

2015-01-20 Thread Jakub Korab
If you have access to ActiveMQ you could try putting the requests onto a JMS queue, and using Message Groups (http://activemq.apache.org/message-groups.html). Putting the item id in the JMSXGroupId header will ensure that only one JMS consumer processes the total set of messages for that item id se

How to handle requests sequentially for a given item

2015-01-20 Thread arthurs
I need to only execute one route request at a time for a given item (ie object processed by the route). So, if the second request with same item id comes in, it waits until the first one completes before continuing with processing. I understand that I can use onCompletion and thread libraries to

Re: simple recipientlist expansion

2015-01-20 Thread James Green
Map? I meant a List on the header, of course. On 20 January 2015 at 16:00, James Green wrote: > I ended up with a Processor that built a new Map on a header iterating > over the media and prefixing each in the header variant. > > I may in-line this in the camel route (as per your example) to lev

Re: simple recipientlist expansion

2015-01-20 Thread James Green
I ended up with a Processor that built a new Map on a header iterating over the media and prefixing each in the header variant. I may in-line this in the camel route (as per your example) to level the knowledge a little better though. Thanks for the suggestions. On 20 January 2015 at 15:16, Jaku

Re: Modifying a shipped TypeConverter

2015-01-20 Thread James Green
Given MongoDB has an ISODate type natively, should the default ObjectMapper be changed within the component itself to not write timestamps as longs? I.e. should this be considered a bug..? On 20 January 2015 at 15:29, Jakub Korab wrote: > I haven't tried this, so it's just conjecture, but you c

Re: Modifying a shipped TypeConverter

2015-01-20 Thread Jakub Korab
I haven't tried this, so it's just conjecture, but you could try to remove the offending type converter from the TypeConverterRegistry and replace it with your own: |CamelContext context = ...| |TypeConverterRegistry converterRegistry = context.getTypeConverterRegistry(); ||converterRegistry.remov

Re: how to run a consumer route once?

2015-01-20 Thread Jakub Korab
Try using pollEnrich(...) to grab the file from S3. http://camel.apache.org/content-enricher.html Jakub On 20/01/15 15:03, aidatechinc wrote: > thank you. my example was using a file, I am aware of the polling stratregy > for a file component. The problem is I am trying to solve is grab once fi

Re: how to run a consumer route once?

2015-01-20 Thread aidatechinc
thank you. my example was using a file, I am aware of the polling stratregy for a file component. The problem is I am trying to solve is grab once file per user request from AWS-S3 and put it in the system. I want it to run once, without deleting the file on AWS. -- View this message in cont

Re: simple recipientlist expansion

2015-01-20 Thread Jakub Korab
One way to do this is to assemble the list of destinations in a header, then reference that. Here's a rough example: .process( new Processor() { public void process(Exchange exchange) { Message in = exchange.getIn(); List mediaList = ((YourPojo) in.getBody()).getMedia();

Modifying a shipped TypeConverter

2015-01-20 Thread James Green
The mongodb component uses Jackson to marshal Object to DBObject. The trouble is that Date becomes long due to the default configuration of Jackson. Is it possible to change this by obtaining that Jackson instance and reconfiguring it? Or must be add a TypeConvertor for our specify type to the re

Re: Camel-CXF: Problems transforming namespace of incoming message

2015-01-20 Thread Aki Yoshida
I don't think the http endpoint can be used to bridge typical soap webservice calls, as there are some mismatches in the behavior between the soap protocol and the plain http protocol. If I understand your scenario, you want to do something like from-cxf:A ---> to-cxf:A if ...some condition... fro