Re: how can i create an async 'to' in a route?

2012-08-15 Thread Claus Ibsen
Hi There is an EIP for that, such as the wire tap. On Thu, Aug 16, 2012 at 8:34 AM, Ittay Dror wrote: > I have a route where I want to asynchronously send to some endpoint. That is, > I want the route to send the message and then finish without waiting for the > endpoint's route to process. > >

Re: Camel usage in Online usecases

2012-08-15 Thread Karthikeyan Muthukumarasamy
Hi Michael, Thanks for the reply. Sure, I will look into the page and will also share my benchmarks with the community. Meanwhile, can you or someone else, please point me to some material on the internet which mentions usage of Camel in online, low-latency applications? Thanks MK On Fri, Aug 10,

Re: Http4 component throws useless NPE if request body is String (instead of InputStream)

2012-08-15 Thread Claus Ibsen
Hi I upgrade camel-http4 to use 4.2.1 by default in the next 2.11 release of Camel https://issues.apache.org/jira/browse/CAMEL-5511 I did not spot any NPE, and thus 4.2.1 seems working fine. On Thu, Aug 16, 2012 at 12:17 AM, pmcb55 wrote: > Hi Claus, > > Ok - I think I've tracked this problem d

how can i create an async 'to' in a route?

2012-08-15 Thread Ittay Dror
I have a route where I want to asynchronously send to some endpoint. That is, I want the route to send the message and then finish without waiting for the endpoint's route to process. How can I do that? Regards, Ittay -- View this message in context: http://camel.465427.n5.nabble.com/how-can-

Re: how to change the default camel test

2012-08-15 Thread surangika ranathunga
That's what I was looking for. Thanks soo much. From: Claus Ibsen To: users@camel.apache.org Sent: Thursday, 16 August 2012 6:05 PM Subject: Re: how to change the default camel test On Thu, Aug 16, 2012 at 1:27 AM, surangika ranathunga wrote: > > > Hi All,

Re: how to change the default camel test

2012-08-15 Thread Claus Ibsen
On Thu, Aug 16, 2012 at 1:27 AM, surangika ranathunga wrote: > > > Hi All, > I am very new to JEE and Apache camel, so need your help. > In order to implement a new end point, I was using the example given in > Chapter 11. This procedure creates a test class that extends CamelTestSupport. > > The

Re: Camel exchange - Multiple File output from processor

2012-08-15 Thread Murari Raghavan
Thanks Willem, this worked perfectly for my scenario. -- View this message in context: http://camel.465427.n5.nabble.com/Camel-exchange-Multiple-File-output-from-processor-tp5717035p5717465.html Sent from the Camel - Users mailing list archive at Nabble.com.

Re: null pointer exception

2012-08-15 Thread m.pryakhin
I've had the same problem with jdk 1.7. The exception happened because of existence of ClassBeanInfoImpl class in the rt.jar in jdk 1.7. The solution was to add jaxb-impl jar to maven dependencies... -- View this message in context: http://camel.465427.n5.nabble.com/null-pointer-exception-tp55

Re: How Do We Specify Operation To Choose In Camel CXf

2012-08-15 Thread anupamsen
http://camel.465427.n5.nabble.com/file/n5717466/camel-example-cxf-proxy.rar camel-example-cxf-proxy.rar I have this in the attached project. But the issue is that the operation name header is not displayed on teh incoming request. I have used the following - -- View this message in context:

Re: Camel & Virgo in Eclipse (with Spring)

2012-08-15 Thread Willem jiang
Hi, I didn't try the Virgo before, but if you are using Apache Karaf or ServiceMix, we just load the camel related feature first ( lots required bundles will be load automatically), then it could be much easy for you to load the application even it just a xml. -- Willem Jiang FuseSource Web

Re: Camel Build Error

2012-08-15 Thread Willem jiang
How did you run the build? As camel-spring has the test dependency of camel-core test jar, you need to install the test.jar when you run the build. You need to use "mvn clean install -Dtest=false" from the root to run the build. -- Willem Jiang FuseSource Web: http://www.fusesource.com (http:/

Re: Http4 component throws useless NPE if request body is String (instead of InputStream)

2012-08-15 Thread pmcb55
Hi Claus, Ok - I think I've tracked this problem down (after a lot of frustration and wasted time!). You should be easily able to reproduce the problem with the code I posted originally if you simply use HttpComponent version 4.2 (i.e. 'httpclient-4.2.jar' and 'httpcore-4.2.jar'). The latest versi

how to change the default camel test

2012-08-15 Thread surangika ranathunga
Hi All, I am very new to JEE and Apache camel, so need your help. In order to implement a new end point, I was using the example given in Chapter 11. This procedure creates a test class that extends CamelTestSupport. The consumer extends a ScheduledPollConsumer, which is supposed to execute a

how to change the default camel test

2012-08-15 Thread surangika ranathunga
Hi All, I am very new to JEE and Apache camel, so need your help. In order to implement a new end point, I was using the example given in Chapter 11. This procedure creates a test class that extends CamelTestSupport. The consumer extends a ScheduledPollConsumer, which is supposed to execute

Customer PollingConsumerPollStrategy but with message header or exchange property

2012-08-15 Thread vishal1981
Hi, I want to log any and all FTP failures when using an FTP consumer. As I understand I have to, 1. Implement -PollingConsumerPollStrategy 2. set throwExceptionOnConnectFailed=true on the FTP URI. (Is there an equivalent one for File endpoint?) 3. Also setting, consumer.bridgeErrorHandler=true to

Testing harness to verify Message Order Preservation

2012-08-15 Thread Sean K
Hi, I am looking into how to build a configuration and verify a test that preserves JMS message order, as describe in the camel features below: http://activemq.apache.org/exclusive-consumer.html http://activemq.apache.org/message-groups.html The basic requirements for message order preservation

Re: exposing different operations under same service in camel + cxf routing.

2012-08-15 Thread anupamsen
By the way I am calling the 2 operations in the WSDL using SOAPUI. -- View this message in context: http://camel.465427.n5.nabble.com/exposing-different-operations-under-same-service-in-camel-cxf-routing-tp5716944p5717444.html Sent from the Camel - Users mailing list archive at Nabble.com.

Re: exposing different operations under same service in camel + cxf routing.

2012-08-15 Thread anupamsen
Following is the header that I see in the logs when run with "mvn camel:run" and routed to log uaing show header option like below- . I don't see no operationName header - Headers:{SOAPAction="http://reportincident.example.camel.apache.org/ReportIncident";, accept-encoding=gzip,deflate, Host=loc

Camel Build Error

2012-08-15 Thread Joe San
[ERROR] Failed to execute goal on project camel-spring: Could not resolve dependencies for project org.apache.camel:camel-spring:bundle:2.11-SNAPSHOT: Could not find artifact org.apache.camel:camel-core:jar:tests:2.11-SNAPSHOT in apache.snapshots ( http://repository.apache.org/snapshots/) -> [Help

Re: Load balancing-camel in real world

2012-08-15 Thread balkishore
Yes I tried! But still it didn't work. I am getting this error with the bridgeEndpoint added in the code. Any help would be very much appreciated. -- View this message in context: http://camel.465427.n5.nabble.com/Load-balancing-camel-in-real-world-tp5717381p5717424.html Sent from the Camel -

Re: Camel & Virgo in Eclipse (with Spring)

2012-08-15 Thread shahed100
In case this helps others Just adding the import to my simple example, and deploying it from Eclipse now works. I do not need to deploy camel related jars.. just have them in the repository. The only thing I had to do was make sure I added the dependency, as my app only has a spring xml file to

Re: Camel & Virgo in Eclipse (with Spring)

2012-08-15 Thread shahed100
Ok, adding Import-Bundle: org.apache.camel.camel-spring;version="[2.10.0,2.10.0]" Causes my app to wait till the pickup directory can be processed, which in turn loads camel. Thanks -- View this message in context: http://camel.465427.n5.nabble.com/Camel-Virgo-in-Eclipse-with-Spring-tp57174

Re: Welcome to my blog mainly about Apache Camel

2012-08-15 Thread michal.warecki
Hi, I've just published new blog post about Monitoring and managing Apache Camel: http://michalwarecki.blogspot.com/2012/08/monitoring-and-managing-apache-camel.html Cheers, Michal -- View this message in context: http://camel.465427.n5.nabble.com/Welcome-to-my-blog-mainly-about-Apache-Came

Re: Camel & Virgo in Eclipse (with Spring)

2012-08-15 Thread shahed100
If I place camel-spring-2.10.0.jar in the pickup directory, it sort of works, but I still need to re-deploy my app as it loads before camel-spring gets loaded. Perhaps I need to add some sort of dependancy in my manifest. -- View this message in context: http://camel.465427.n5.nabble.com/Cam

FTP2 - readlock and lastmodified timestamps

2012-08-15 Thread Ralf Steppacher
Hello all, I am having a problem with FTP2 and the lastmodified timestamps it reports. I download files from an FTP site where an external data provider places a set of files under the same name every 15 minutes. I use the "changed" readlock strategy to avoid downloading files that are currently w

Re: Proof of concept for Camel Web Interface

2012-08-15 Thread Preben.Asmussen
Hi Lars I had a look at Jolokia last year and was impressed by it's usability for exposing jmx using http. Basically I wanted to use the Camel stats. for monitoring purposes for our custom monitoring system. At the end I found that the jmx stats wasn't enough to give you a reliable picture of the

Camel & Virgo in Eclipse (with Spring)

2012-08-15 Thread shahed100
I am new to Camel / Virgo, but have managed to get Camel working in Virgo, by 1. Adding all the jars in Camel 2.10 release to a Virgo repository 2. Deploying camel-spring bundle (Which then loads camel-core) 3. Deloying a sample app which has only a camelContext which starts a timer and logs the

onCompletion with onWhen predicate

2012-08-15 Thread Hilde
Hello folks! I have figured out that onCompletion().onWhen() cannot be used multiple. Actually onCompletion().onWhen() suggests to use it multiple erroneously. I wrote the following route: from("seda:" + SedaDirectDestinations.SEDA_LOAD).routeId(ROUTE_ID) .onCompletion().onWhen(simple("${hea

Re: enrich and pollEnrich

2012-08-15 Thread Joe San
Claus. I plead that you listen to this. Camel in Action is an awesome resource. I would request you to make it even more awesome by detailing a bit more on the core concepts. Regards, Jothi On Wed, Aug 15, 2012 at 4:49 PM, Vincent Nonnenmacher < vincent.nonnenmac...@gmail.com> wrote: > I concur

Re: enrich and pollEnrich

2012-08-15 Thread Vincent Nonnenmacher
I concur to this, the notions aren't very clear at the beginning on an otherwise very well written book. A phrase like this "The TO .. is "always" a producer.." along with very clear schemas could help a lot, because somehow its counter intuitive, until the light come up latter by practicing. It

Re: Load balancing-camel in real world

2012-08-15 Thread Willem jiang
Did you have chance to enable the bridgeEndpoint option as I showed ? -- Willem Jiang FuseSource Web: http://www.fusesource.com (http://www.fusesource.com/) Blog: http://willemjiang.blogspot.com (http://willemjiang.blogspot.com/) (English) http://jnn.javaeye.com (http://jnn.javaeye.c

Re: enrich and pollEnrich

2012-08-15 Thread Joe San
Yes. Your statement "The TO in the Camel routes is *always* a producer, eg you produce a message to an endpoint. In the http endpoint you would then do a request/reply to the http service. So the message after the TO will contain the response from the http service, and whatever the message was

Re: enrich and pollEnrich

2012-08-15 Thread Claus Ibsen
On Wed, Aug 15, 2012 at 3:32 PM, Joe San wrote: > Thanks for the explanation. > > From your example in the Camel in Action book in Chapter 3: > > from("quartz://report?cron=0+0+6+*+*+?") > .to("http://riders.com/orders/cmd=received&date=yesterday";) > .process(new OrderToCsvProcessor()) > .to("fil

Re: Load balancing-camel in real world

2012-08-15 Thread balkishore
Thanks for replying. I changed from("jetty://http://localhost:8080/";) in my code, and still i get the same error, when i send a request. But when i type http://localhost:8080/ on my browser, i get an error like this: java.lang.IllegalArgumentException: Invalid uri: /. If you are forwarding/bridg

Re: enrich and pollEnrich

2012-08-15 Thread Joe San
Thanks for the explanation. >From your example in the Camel in Action book in Chapter 3: from("quartz://report?cron=0+0+6+*+*+?") .to("http://riders.com/orders/cmd=received&date=yesterday";) .process(new OrderToCsvProcessor()) .to("file://riders/orders?fileName=report-${header.Date}.csv"); Your

Re: Load balancing-camel in real world

2012-08-15 Thread balkishore
Thanks for replying. Yeah when I input http://172.28.39.138:8080/ in my browser, apache tomcat page opens. As it is a backend server, and it runs tomcat in it which is listening on the port 8080 for requests. I am still struck in this part. Am I doing something wrong? Any help would be very much a

Re: enrich and pollEnrich

2012-08-15 Thread Claus Ibsen
On Wed, Aug 15, 2012 at 2:53 PM, Joe San wrote: > Camel Riders, > > I fail to fathom the fact that enrich works with a Producer EndPoint and > pollEnrich works with a Consumer EndPoint. Is there a design consideration > behind this mechanism? Can anyone please clarify why a pollEnrich should be >

Re: Load balancing-camel in real world

2012-08-15 Thread Willem jiang
Current jetty component have some trouble to setup right context path if you don't specify it like this from("jetty://http://localhost:8080";) You can change the uri like this from("jetty://http://localhost:8080/";) if you want to implement a proxy you need to setup the route like this from("jett

enrich and pollEnrich

2012-08-15 Thread Joe San
Camel Riders, I fail to fathom the fact that enrich works with a Producer EndPoint and pollEnrich works with a Consumer EndPoint. Is there a design consideration behind this mechanism? Can anyone please clarify why a pollEnrich should be used with a Consumer EndPoint and not with a Producer EndPoi

Re: Load balancing-camel in real world

2012-08-15 Thread Claus Ibsen
On Wed, Aug 15, 2012 at 2:44 PM, balkishore wrote: > Thanks for replying. But I even tried using 0.0.0.0. Still my problem is not > resolved. > Are you sure the SOAP services on those remote server is exposed at the root, eg this url? http://172.28.39.138:8080/ For example if you type that in a

Re: Proof of concept for Camel Web Interface

2012-08-15 Thread Claus Ibsen
Hi Thanks for sharing this with the community. Yes Jolokia is a interesting project. For example it can offer a nice REST api on top of the JMX API we have in Camel. We have on the Camel roadmap for 3.x to offer a REST management API, but Jolokia may just be the glue we decide to use, instead of

Re: Load balancing-camel in real world

2012-08-15 Thread balkishore
Thanks for replying. But I even tried using 0.0.0.0. Still my problem is not resolved. -- View this message in context: http://camel.465427.n5.nabble.com/Load-balancing-camel-in-real-world-tp5717381p5717383.html Sent from the Camel - Users mailing list archive at Nabble.com.

Re: Load balancing-camel in real world

2012-08-15 Thread Christian Müller
It's good practice to use 0.0.0.0 instead of localhost if you want to listen on all network interfaces. Best, Christian Sent from a mobile device Am 15.08.2012 14:15 schrieb "balkishore" : > Dear memebers, > This would be my first post in this forum and I am glad. I have started > using camel a

Load balancing-camel in real world

2012-08-15 Thread balkishore
Dear memebers, This would be my first post in this forum and I am glad. I have started using camel a while back for a project of mine to create a load balancing application. Well to start with, My load balncer would listen to a port, lets say 8080 and would balance all the incoming SOAP requests t

Re: cxfrs: GET and POST handling in bean

2012-08-15 Thread Sergey Beryozkin
On 15/08/12 04:19, paramjyotsingh wrote: Is it not possible to handle it somehow in camel routes. Is there any way Camel identifies the request type like GET, POST, PUT or DELETE as we have for restful service and invoke the annotated method. I know i can use JAX-RS to handle calls to implementa

Re: class path resource [META-INF/spring/] cannot be resolved

2012-08-15 Thread Babak Vahdat
Hi The path to your spring config should match the expression "META-INF/spring/*.xml". For example: "META-INF/spring/mycontext.xml" If not you can specify the path explicitly using the org.apache.camel.spring.Main.setApplicationContextUri() method. For example main.setApplicationContextUri("

class path resource [META-INF/spring/] cannot be resolved

2012-08-15 Thread Eamonn
Hi, I'm getting a error when i try to run the camel context for my application. I'm running it on a Ubuntu VM. It was working fine when we made the machine image a few months ago, but now that we have gone back to it we get an error. Any suggestions or help would be greatly appreciated. Full sta

Re: Splitter + aggregator + dynamic timeout

2012-08-15 Thread Babak Vahdat
Hi Alex, Regarding your "open question" by your mail below please find a slightly modified version of your routing which now would pass. See also the "XXX" comments of mine. Hope this helps. Babak public class SplitterWithAggregatorTest extends CamelTestSupport { @Test public void shoul

Re: Http4 component throws useless NPE if request body is String (instead of InputStream)

2012-08-15 Thread Claus Ibsen
Hi I cannot reproduce this on trunk. Works fine for me. I get a response from google, eg their html response page. Are you behind some http proxy or whatnot? Where did you spot the cause exception? Maybe you can dig the stracktrace etc. On Tue, Aug 14, 2012 at 10:46 AM, pmcb55 wrote: > Hi Cla

Re: returning xml file content as response

2012-08-15 Thread Henryk Konsek
Hi, > In my camel config, I am trying to handle exception be returning a static > xml response, indicating that there was an error. If the response is static indeed, you can use Java DSL and set the body to constant value. from("direct:invalidCredentialQueue"). setBody(constant(MyMessageUtil.get