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 =
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) {
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
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
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
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
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
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
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
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
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,
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
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
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.
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,
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:
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
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
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:
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
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)
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.
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:
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
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
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
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
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
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
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
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
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.
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
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
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,
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
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,
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
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:
39 matches
Mail list logo