Camel running continuously

2011-11-21 Thread southtechie
I wrote a came route in beans.xml file to transfer files from one folder to another. When I run file transfer happens but the camel does not stop. The funny th

Re: Camel running continuously

2011-11-21 Thread Bilgin Ibryam
There are similar questions and answers on the user mailing list where you can find the answer, here is one: http://camel.465427.n5.nabble.com/How-to-make-camel-stop-automaticaly-td465989.html Bilgin On Mon, Nov 21, 2011 at 7:57 AM, southtechie wrote: > I wrote a came route in beans.xml file to

Re: invoking bean from CAMEL route

2011-11-21 Thread Bilgin Ibryam
"direct" endpoint is not going to generate messages for you. You have to send a message to it from another route or java code. It is used mainly to connect routes synchronously, take a look here http://camel.apache.org/direct.html Bilgin On Mon, Nov 21, 2011 at 2:47 AM, newbiee wrote: > hi Bilgi

Re: Camel running continuously

2011-11-21 Thread Ioannis Canellos
> When I run file transfer happens but the camel does not stop. The funny > thing is whatever files I paste in source folder is transferred to the > target again and again. How to stop the camel running once the transfer is > over? > If I understand the question correctly you want to execute the r

Re: Camel running continuously

2011-11-21 Thread Jean-Baptiste Onofré
Around the same topic, I blogged about how to use Camel to implement batches (run once and stop, with another route to control the first one): http://blog.nanthrax.net/2011/08/use-camel-cxf-and-karaf-to-implement-batches/ Regards JB On 11/21/2011 11:33 AM, Ioannis Canellos wrote: When I run f

Re: Camel running continuously

2011-11-21 Thread Freeman Fang
Hi, Do you mean file consumer consume same file over and over again? If so, you just need add noop=true to from uri, which can avoid consuming the same files over and over again. You may need take a look at [1] to get more details how to configure file component. [1]http://camel.apache.org

Re: CSV to database

2011-11-21 Thread Idriss
Thank you for your reply Christian, I managed to extract data from a database using JPA and insert them into another database using a Processor, but this procedure is very long. Is there a way to optimize the insertion of these data in the database? Regards Idriss -- View this message in context

Re: Camel running continuously

2011-11-21 Thread Johm Mac
On 21/11/2011 10:33, Ioannis Canellos wrote: When I run file transfer happens but the camel does not stop. The funny thing is whatever files I paste in source folder is transferred to the target again and again. How to stop the camel running once the transfer is over? If I understand the questi

Re: NETTY component for network programming

2011-11-21 Thread Ioannis Canellos
Theoretically, you could use camel-netty or camel-mina to do so, but I will propose a more easy approach which is camel-exec: http://camel.apache.org/exec.html Using camel exec you could execute commands in your system. So I guess that something like ssh username:host -C command would do the trick

Unit test failure on trunk in camel-saxon

2011-11-21 Thread bvahdat
Hi, As my posts don't get accepted @ dev here a link to my 2 cents: http://camel.465427.n5.nabble.com/Unit-test-failure-on-trunk-in-camel-saxon-tp5009713p5010536.html Question: if I would subscribe to dev-subscr...@camel.apache.org as provided by [1] would it then be accepted? [1] http://camel.

Re: A High Level Data Translation Question

2011-11-21 Thread Castyn
Well I suppose the interesting thing is that when the initial request is sent to the cxf web service endpoint, I am just using a velocity template as the message since it is static, so the cxf endpoint is in MESSAGE format for that. The reply back from the cxf endpoint then would be what needs to

Re: A High Level Data Translation Question

2011-11-21 Thread Castyn
Actually for a bit more clarity, the route is as follows: // Static SOAP Message // This is a remote version of servicemix where this queue is processed and responded with a complex SOAP XML message At this point is where I'd like to begin transforming the message, and am

Re: invoking bean from CAMEL route

2011-11-21 Thread Hadrian Zbarcea
@newbiee, a lot of your questions would be answered by reading through the camel wiki and looking at the code/tests. Reading the manual [1] (older versions in pdf and html are also available [2]) may also be very helpful and an excellent starting point. Cheers, Hadrian [1] http://camel.apache

Message from Amazon SQS and then File from Amazon S3

2011-11-21 Thread Patrick Dreyer
Hi, I couldn't really make up my head on how to implement a route/workflow as follows: 1. Listen for Amazon SQS message 2. Extract Amazon S3 URL contained in the message 3. Fetch file the URL is pointing to from Amazon S3 4. Process file 5. Send email or send message to different Amazon SQS Am

Re: A High Level Data Translation Question

2011-11-21 Thread Castyn
I created a custom processor per the links posted previously. Once in a custom processor, is there a way to marshal the message into java objects? Or is there a good way to parse and edit the xml message from within the processor, or should I just write base XML parsing in java? -- View this mes

RE: Queue/Dequeue perfomance InOut ExchangePattern

2011-11-21 Thread Carlos Manuel Figueiredo
How do I use ConsumerTemplate? This is my attempt. Created a new Processor: // Dequeue .when(and(header("CamelHttpUri").regex(".*/my-queue.*"), header("CamelHttpMethod").isEqualTo("GET"))) .setExchangePattern(ExchangePattern.InOut) .process(new InOutProcessor()) And inside it I

Re: Stop a route for unit testing

2011-11-21 Thread Christian Müller
Hello Willem, hello list! Today I found a bit time to look again into this issue and I could solve it (will provide a unit test later for this). The trick was to use context.stopRoute(routeId); instead of ((DefaultRoute) context.getRoute(routeId)).stop(); // doesn't work Also context.removeRoute

Re: Unit test failure on trunk in camel-saxon

2011-11-21 Thread Christian Müller
As mentioned in [1]: "You have to be a subscriber of the Camel mailinglist to be able to post on the user forum... If you are not a subscriber your post will not be forwarded and thus most people will not see your post." [1] http://camel.apache.org/discussion-forums.html Best, Christian On Mon,

Re: Unit test failure on trunk in camel-saxon

2011-11-21 Thread Daniel Kulp
On Monday, November 21, 2011 6:35:47 PM Christian Müller wrote: > As mentioned in [1]: > "You have to be a subscriber of the Camel mailinglist to be able to post on > the user forum... If you are not a subscriber your post will not be > forwarded and thus most people will not see your post." > > [

converting form JAVA DSL to Spring DSL

2011-11-21 Thread newbiee
I have following JAVA DSL: from("timer://myTimer?period=2000") .setBody().simple("Current time is ${header.firedTime}") .to("stream:out"); how can I converted the first and third lines to Spring DSL: How can I convert .setBody().simple("Current time is ${header.firedTime}") t

Re: Remotely pulling messages using CAMEL

2011-11-21 Thread newbiee
Hadrian: Thank you for putting the code together. I feel that I am gaining a lot from your code as I go through it again and again. Your code shows how to establish TCP connection. Can you also give few hints about how to send commands to the Digi and get the response back. I want to know, if

Re: invoking bean from CAMEL route

2011-11-21 Thread newbiee
Thank you to both Bilgin and Hadrian -- View this message in context: http://camel.465427.n5.nabble.com/invoking-bean-from-CAMEL-route-tp5008230p5011239.html Sent from the Camel - Users mailing list archive at Nabble.com.

Re: Remotely pulling messages using CAMEL

2011-11-21 Thread Hadrian Zbarcea
Sure. Hadrian On 11/21/2011 01:03 PM, newbiee wrote: Hadrian: Thank you for putting the code together. I feel that I am gaining a lot from your code as I go through it again and again. Your code shows how to establish TCP connection. Can you also give few hints about how to send commands to th

Re: Unit test failure on trunk in camel-saxon

2011-11-21 Thread bvahdat
Hi Dan & Christian, thanks for your hints. @Christian what I meant was not 'Camel User List' *but* 'Camel Developer List'. Anyway now in addition to 'users@camel.apache.org' (which I've subscribed since last year) now I also managed to subscribe to 'd...@camel.apache.org' as well: ---

Re: Remotely pulling messages using CAMEL

2011-11-21 Thread newbiee
Hadrian; I am executing each route one by one. Here is what I have done: First route: It runs successfully and I am able to see all the host:IP in the digiQueue Nex I add the second route: ${body}

Re: Writing own Camel Components

2011-11-21 Thread Daniel Kulp
On Wednesday, November 09, 2011 12:49:09 PM Ashwin Karpe wrote: > Hi, > > Unless I am mistaken, RabbitMQ is released under the Mozilla Public License > 1.1. This license version is not compatible with Apache License v2.0. There > was talk of having a compatible Mozilla Public License v 2.0. If Rab

Re: converting form JAVA DSL to Spring DSL

2011-11-21 Thread Bilgin Ibryam
If you have xml autocompletion in your IDE, you should use it. Current time is ${header.firedTime} Bilgin On Mon, Nov 21, 2011 at 5:55 PM, newbiee wrote: > I have following JAVA DSL: > > from("timer://myTimer?period=2000") > .setBody().simple("Current time is ${header.fir

Re: converting form JAVA DSL to Spring DSL

2011-11-21 Thread newbiee
Thanks Bilgin. I'm not using IDE but will try using it. -- View this message in context: http://camel.465427.n5.nabble.com/converting-form-JAVA-DSL-to-Spring-DSL-tp5011220p5011615.html Sent from the Camel - Users mailing list archive at Nabble.com.

RE: converting form JAVA DSL to Spring DSL

2011-11-21 Thread Omar Atia
Is there any IDE different than Eclipse Plugin for apache camel ? -Original Message- From: newbiee [mailto:m_ess...@hotmail.com] Sent: Monday, November 21, 2011 10:39 PM To: users@camel.apache.org Subject: Re: converting form JAVA DSL to Spring DSL Thanks Bilgin. I'm not using IDE

Re: converting form JAVA DSL to Spring DSL

2011-11-21 Thread Bilgin Ibryam
I'm using IntelliJ but Eclipse or any editor supporting xml with schemas should be fine. Bilgin On Mon, Nov 21, 2011 at 8:58 PM, Omar Atia wrote: > Is there any IDE different than Eclipse Plugin for apache camel ? > > -Original Message- > From: newbiee [mailto:m_ess...@hotmail.com] > Sen

RE: converting form JAVA DSL to Spring DSL

2011-11-21 Thread Omar Atia
Eclipse can't support XML , is there any maven plugin for IntelliJ as I'm downloading it now . -Original Message- From: Bilgin Ibryam [mailto:bibr...@gmail.com] Sent: Monday, November 21, 2011 11:05 PM To: users@camel.apache.org Subject: Re: converting form JAVA DSL to Spring DSL I'm us

Custom Processor with XPath

2011-11-21 Thread Castyn
I am attempting to convert a SOAP message from one message format to another, and along the way calculating and aggregating data. At any rate, I am trying to create a custom processor to do this, within which I will have xpath calls and such. Currently I am running into an issue trying to convert

No consumers available on endpoint: Endpoint[direct://start]

2011-11-21 Thread newbiee
I have following route: ${body} netty:tcp://${body}?sync=true DigiUri DigiUri If I replace: DigiUri with: The value of "DigiUri" is printed on the command prompt. But with

Re: No consumers available on endpoint: Endpoint[direct://start]

2011-11-21 Thread Christian Schneider
Well it means that you call a direct endpoint and no one is listening on it. What do you want to achieve with direct:start? Christian Am 21.11.2011 22:30, schrieb newbiee: I have following route: ${body} netty:tcp://${body}?sync=true DigiUri

Re: No consumers available on endpoint: Endpoint[direct://start]

2011-11-21 Thread Hadrian Zbarcea
Of course that's what happens. If you send it to stream:out (if it works you probably added a dependency on camel-stream) it will use a Producer to send it to std:out (as that is the behavior of camel-stream with a stream:out uri). If you send it to direct:start, the behavior of the direct com

Re: No consumers available on endpoint: Endpoint[direct://start]

2011-11-21 Thread newbiee
Thanks Hadrian, I'm going to fix it as you have explained. -- View this message in context: http://camel.465427.n5.nabble.com/No-consumers-available-on-endpoint-Endpoint-direct-start-tp5011742p5011993.html Sent from the Camel - Users mailing list archive at Nabble.com.

Failed delivery for exchangeId: On delivery attempt:

2011-11-21 Thread newbiee
Hadrian: thanks for your valuable feedback. this is my partial route: ${body} netty:tcp://${body}?sync=true DigiUri The first route (from above) works fine. in the second route, it works

Re: JMX issue when using Camel in ServiceMix

2011-11-21 Thread eliotc
Hi JB, Thanks for your prompt reply! I don't have to create a dedicated registry for camel as long as I can still see camel routes through ServiceMix/Karaf MBeanService/registry. However, I am not able to verify this because the default ServiceMix JMX connector URI does not work neither: */servi

Re: How to create a Proxy per request

2011-11-21 Thread KingAndrew
Hi Claus, In the links you provided it shows how to make a proxy for a particular Class. I want to make a proxy for a particular Object. I want to replace this: RequestImpl br = (RequestImpl) tmpHolder.get(ndx); // <- br is the Impl retList[ndx] = (RequestInterface) javax.rmi.PortableRemoteObj

Re: How to create a Proxy per request

2011-11-21 Thread KingAndrew
Ok so with messaging we are de-coupled do the proxy can accept an endpoint: Echo service = ProxyHelper.createProxy(context.getEndpoint("direct:echo"), Echo.class); I still need to pass around a reference to a particular Object. So I guess my question should be how I generate an Exporter on the

Re: How to create a Proxy per request

2011-11-21 Thread KingAndrew
Correction: the last call should have been *getProxyForService*() instead of getService(). On Mon, Nov 21, 2011 at 8:33 PM, Andrew Boyd wrote: > Ok so with messaging we are de-coupled do the proxy can accept an endpoint: > > Echo service = ProxyHelper.createProxy(context.getEndpoint("direct:echo

Re: converting form JAVA DSL to Spring DSL

2011-11-21 Thread Taariq Levack
Yes, IDEA has great maven support out of the box. On Mon, Nov 21, 2011 at 11:11 PM, Omar Atia wrote: > Eclipse can't support XML , is there any maven plugin for IntelliJ as I'm > downloading it now . > > -Original Message- > From: Bilgin Ibryam [mailto:bibr...@gmail.com] > Sent: Monday,

Re: Camel running continuously

2011-11-21 Thread southtechie
Thanks a lot Bilgin Ibryam. -- View this message in context: http://camel.465427.n5.nabble.com/Camel-running-continuously-tp5009748p5012463.html Sent from the Camel - Users mailing list archive at Nabble.com.

Re: Camel running continuously

2011-11-21 Thread southtechie
Hi Freeman-2, Thanks for your reply. I tried your suggestion but it does not transfer any file instead camlelock file is created. Actually I want to stop Camel once the transfer of existing files in the source folder is done. -- View this message in context: http://camel.465427.n5.nabble.com/C

Camle ActiveMQ connection polling and threading issue

2011-11-21 Thread cbenaveen
Hi All, I am on my way to write a POC, in which i am facing issues related to threads. I have ActiveMQ (V5.3.0) running on my remote Linux (RHEL) box and which can be reached via tcp protocol and 62616 port. Here is my usecase which i am trying to implement in the POC. 1.My JMS client is runnin

Too many OnCompletion threads

2011-11-21 Thread Zhemzhitsky Sergey
Hi there, I’m using camel 2.6.0 within servicemix and have about 50 camel applications deployed.. Now I have about 260 “OnCompletion” threads which seems to be a lot, especially because the number of camel applications is going to be increased significantly on my environment. Is there any way