Re: Endpoint exception handling

2012-02-22 Thread Alex Anderson
Hi Claus Tuomas, I faced a similar problem a couple of weeks ago and came to the following solution: The exception can be passed to a route in the Consumer like so: public void handleEndpointException(EndpointException ex) { Exchange exchange =

Re: Handling Endpoint failure

2012-02-22 Thread Alex Anderson
Hi Ashwin, Thanks for your help on this. I ended up solving this by creating an Exchange with the Exception attached, like so: The exception can be passed to a route in the Consumer like so: class MyConsumer { ... public void handleEndpointException(EndpointException ex) {

batch processing

2012-02-22 Thread Ben van Klinken
Hi, I'm pretty new to camel so I may be missing something. I have discovered I can have a batch consumer, which downloads N items from the source, but I'd like to have a batch processor and batch producer. It's not very efficient for me to process an message at a time, so I'm looking to process a

exchange pattern in exchange and in endpoint

2012-02-22 Thread Babel
Hello everyone, I'm still working on my component and would like to be sure on that point, about the exchange pattern which is part of the exchange and the endpoint: the exchange pattern contained in the exchange is use on the whole route? on that route, one endpoint may have a different pattern

exchange pattern in exchange and in endpoint

2012-02-22 Thread Babel
Hello everyone, I'm still working on my component and would like to be sure on that point, about the exchange pattern which is part of the exchange and the endpoint: the exchange pattern contained in the exchange is use on the whole route? on that route, one endpoint may have a different pattern

Re: Endpoint exception handling

2012-02-22 Thread Claus Ibsen
On Wed, Feb 22, 2012 at 8:59 AM, Alex Anderson a...@frontlinesms.com wrote: Hi Claus Tuomas, I faced a similar problem a couple of weeks ago and came to the following solution: The exception can be passed to a route in the Consumer like so:        public void

Re: jms concurrentConsumers is not competing consumers

2012-02-22 Thread Pham Ngoc Hai
Hi Jim, Beside Babak's reply, if you still want the competing behavior, you can try the asyncConsumer option on the consumer, be warned about the message's order, I have not tested that myself though. Regards, Ngoc Hai. From: Jim Newsham

Passing environment variable to URI in Spring XML

2012-02-22 Thread saiya-jin
Hello, I googled quite a lot, but I didn't find something that would work for me. Situation is pretty simple: I need to use a JVM variable (passed when launching process with -Dtopdir=XXX) of current folder where app is residing. Because of a way app is installed (symlinks to launch scripts etc) I

Re: Passing environment variable to URI in Spring XML

2012-02-22 Thread Claus Ibsen
Hi See this FAQ http://camel.apache.org/how-do-i-use-spring-property-placeholder-with-camel-xml.html On Wed, Feb 22, 2012 at 11:12 AM, saiya-jin martin.franci...@barclayswealth.com wrote: Hello, I googled quite a lot, but I didn't find something that would work for me. Situation is pretty

Re: exchange pattern in exchange and in endpoint

2012-02-22 Thread Claus Ibsen
On Wed, Feb 22, 2012 at 10:03 AM, Babel chpa...@gmail.com wrote: Hello everyone, I'm still working on my component and would like to be sure on that point, about the exchange pattern which is part of the exchange and the endpoint: the exchange pattern contained in the exchange is use on the

Re: Asynchronous socket read-write via camel

2012-02-22 Thread Claus Ibsen
There is a person working on camel-mina2 component to enhance it to support async req/reply with correlation. eg what seems like what you are looking for. There is some JIRA tickets about this. The current behavior for req/reply over netty/mina/mina2 is a 1:1 message solution. On Wed, Feb 22,

Re: Synchronizing event with asynchronous route

2012-02-22 Thread Claus Ibsen
Camel has a in-flight registry which you can query number of in-progress messages. Maybe that can help you, to avoid using sync locks. On Tue, Feb 21, 2012 at 12:41 PM, edvicif edvi...@gmail.com wrote: Hi I have a synchronization issue, which I wasn't able to sort out with core camel

Re: batch processing

2012-02-22 Thread Claus Ibsen
Hi What kinda of consumer are you using? If you build your custom consumer, you can just let it pickup N messages and store them as a List in the message body. You can use the aggregator EIP to aggregate N Camel messages into a combined single message. http://camel.apache.org/aggregator2 Take a

Re: Asynchronous socket read-write via camel

2012-02-22 Thread winks
OK, thank you both. -- View this message in context: http://camel.465427.n5.nabble.com/Asynchronous-socket-read-write-via-camel-tp5503650p5504809.html Sent from the Camel - Users mailing list archive at Nabble.com.

Re: Endpoint exception handling

2012-02-22 Thread Alex Anderson
Thanks for the confirmation that this is ok, Claus. Are there any other ways to do this within Camel, or would there otherwise need to be an external event listener to catch problems within the Endpoint? Alex On 22 February 2012 13:16, Claus Ibsen claus.ib...@gmail.com wrote: On Wed, Feb 22,

How did camel put the originalMessage to DLQ?

2012-02-22 Thread cmland
If necessary, we can put originalMessage to DLQ. I want to know how camel get the originalMessage and deliver to DLQ? I search for the camel API but find nothing. Any help is highly appreciated. -- View this message in context:

Re: How did camel put the originalMessage to DLQ?

2012-02-22 Thread Christian Schneider
The best way to achieve this is to use a transactional route, roll it back on error and let the messaging system move the message to the DLQ. Christian Am 22.02.2012 12:53, schrieb cmland: If necessary, we can put originalMessage to DLQ. I want to know how camel get the originalMessage

Using adviceWith in CamelSpringTestSupport

2012-02-22 Thread Preben.Asmussen
Hi Seems that there is an error in Camel test support for CamelSpringTestSupport when u want to use adviceWith on a Spring DSL defined route. @Override public boolean isUseAdviceWith() { // tell we are using advice with, which allows us to advice the route

Re: Synchronizing event with asynchronous route

2012-02-22 Thread edvicif
You mean http://camel.apache.org/maven/camel-2.7.0/camel-core/apidocs/org/apache/camel/impl/DefaultInflightRepository.html DefaultInflightRepository , what used at durring shutdown? I'll take a look. -- View this message in context:

Re: Using adviceWith in CamelSpringTestSupport

2012-02-22 Thread Claus Ibsen
Hi There is a method you need to override, and return 0 for getExepctedRoute or something like that. But yeah I think we can remove that old assertion, as its not as relevant anymore. I guess it was used as a failsafe to ensure the spring bits get started up. Its from the old 1.x days. Feel

Re: Grouping lines while streaming

2012-02-22 Thread Anurag Sharma
Thank you Willem. Kind Regards, Anurag On Monday, February 20, 2012, Willem.Jiang [via Camel] wrote: You can also create a customer processor[1] to combine the list of object into a String like this from(stream:file?fileName=src/data/webservices_20090723_001_trunc.loggroupLines=2)

Re: Using adviceWith in CamelSpringTestSupport

2012-02-22 Thread Preben.Asmussen
Thans Created https://issues.apache.org/jira/browse/CAMEL-5028 -- View this message in context: http://camel.465427.n5.nabble.com/Using-adviceWith-in-CamelSpringTestSupport-tp5504936p5505087.html Sent from the Camel - Users mailing list archive at Nabble.com.

cxf:bean external webservice can't find

2012-02-22 Thread Filippo Balicchia
Hello I start to play with camel:cfx version 2.8.3 when i try to call my service and on the log i receive org.apache.cxf.service.factory.ServiceConstructionException: Could not find definition for service {http://wse.my.it/}myService. From camel point of view I use the following definition:

Multiple timers with same name in same context

2012-02-22 Thread Preben.Asmussen
Hi You should be to create multiple timers wit the same name in a Context. According to http://camel.apache.org/timer.html if you create a timer with the same name it will only create one Timer object that will be shared across endpoints. so this should be legal: camelContext id=myContext

Re: Multiple timers with same name in same context

2012-02-22 Thread Claus Ibsen
Hi If the uri is slightly different then that ought to work, eg such as different delay etc. But I guess the endpoint should support multiple consumers by default. Could you log a JIRA. On Wed, Feb 22, 2012 at 2:40 PM, Preben.Asmussen p...@dr.dk wrote: Hi You should be to create multiple

Re: Endpoint exception handling

2012-02-22 Thread Claus Ibsen
On Wed, Feb 22, 2012 at 12:02 PM, Alex Anderson a...@frontlinesms.com wrote: Thanks for the confirmation that this is ok, Claus.  Are there any other ways to do this within Camel, or would there otherwise need to be an external event listener to catch problems within the Endpoint? There is a

Re: Endpoint exception handling

2012-02-22 Thread Alex Anderson
Thanks for the clarification, Claus. I had assumed initially that ExceptionHandler was the way to go, but (unsurprisingly) I couldn't find a need way to configure it. Propagating Exceptions into the consumer's processor will do me for now, but I look forward to seeing more development in this

Re: Multiple timers with same name in same context

2012-02-22 Thread Reuben Garrett
I have a similar scenario in which I use a single timer endpoint that multicast/s to different vm: or seda: queues containing the real consumers. Could that be a good work-around in the interim? ~ RNPG On Wed, Feb 22, 2012 at 07:46, Claus Ibsen claus.ib...@gmail.com wrote: Hi If the uri is

How to create a dynamic route based on some properties

2012-02-22 Thread Nikhil Shambhu
Hello I am using camel 2.8.1 I am trying to create a route dynamically based on some properties in a properties file which looks like this Subscribers = s1,s2,s3 // A list of subscribers // Following properties are repeated for each subscriber. I am posting only one subscriber

How to create a dynamic route based on some properties

2012-02-22 Thread nikhil
Hello I am using camel 2.8.1 I am trying to create a route dynamically based on some properties in a properties file which looks like this Subscribers = s1,s2,s3 // A list of subscribers // Following properties are repeated for each subscriber. I am posting only one subscriber properties

Re: Multiple timers with same name in same context

2012-02-22 Thread Preben.Asmussen
Hi Ruby yeah - multicast was my first approach, but we wanna be able to stop/start each timer route independently via jmx, and I guess when you multicast to a route that has been stoppen/suspended an exception is thrown. Of course this could be handled, but since they should be be independent in

Re: RE : Usage of server managed thread of Websphere

2012-02-22 Thread David Karlsen
Does it use the taskexecutor abstraction? If so you can use: http://static.springsource.org/spring/docs/2.5.x/api/org/springframework/scheduling/commonj/WorkManagerTaskExecutor.html 2012/2/21 achalam aadi.cha...@gmail.com: Hi, We are using websphere7.1 with Springframework3.0.4 and camel2.9.

Re: RE : Usage of server managed thread of Websphere

2012-02-22 Thread Preben.Asmussen
Hi David I started som work on integrating Camel with jee workmanagers some time ago. I never got to finish it because I ran into truble on Weblogic being able to release the workers/workmanagers again. And now we are running just fine without using any workmanagers on WLS :-) If you can use it

Re: Exception while using jaxb inside xml

2012-02-22 Thread Christian Müller
I did not mean jaxb.jar. I talk about camel-jaxb.jar. Christian On Wed, Feb 22, 2012 at 6:03 AM, Samruben ramyasri@gmail.com wrote: Yes i added jaxb jar -- View this message in context: http://camel.465427.n5.nabble.com/Exception-while-using-jaxb-inside-xml-tp5503335p5504128.html Sent

Re: jms concurrentConsumers is not competing consumers

2012-02-22 Thread Jim Newsham
Hi Ngoc Hai, Thanks for the suggestion, the asyncConsumer option looks like it might work. I actually implemented another workaround which is already working for me, so I won't be trying the asyncConsumer option for now. I wish I had known about the asyncConsumer option earlier though,

Re: cxf:bean external webservice can't find

2012-02-22 Thread Willem Jiang
Hi, Can I know how did you get the class it.MyService? I guess that you may specify a wrong Service Endpiont Interface. Please make sure it is a Interface which is generated from the WSDL that you specified. On Wed Feb 22 21:40:17 2012, Filippo Balicchia wrote: Hello I start to play with

How to use escape tool ($esc.xml($somestrwithspclchars)) in camel velocity template

2012-02-22 Thread ramesri
Hi All I am a new user and would like to say Hello to all . I am trying to use the $esc.xml in a velocity template. The velocity component is invoked part of a camel route deployed in ServiceMix. I am using $esc.xml for only one tag as addressLine1$esc.xml($headers.addrLine1))/addressLine1,

Re: Return type of processed zip file when using Camel Zip component

2012-02-22 Thread Claus Ibsen
On Wed, Feb 22, 2012 at 5:34 PM, James Morgan james.morga...@gmail.com wrote: Hi, I'm using Camel to process files (zipping pdfs) before being sent to AWS using the Camel AWS component but I'm having trouble working out what is created, where it is created and how to access the body once its

onException problem

2012-02-22 Thread cmland
I use the globel OnException to catch exception , and before deliver to the DLQ,I use a process.my problem is that : when the process occur a exception, the route roll back.the message route ,and roll back again... It has been circulating. cxf version 2.6.0, my xml configuration like this: