Looking for quartz Job examples.

2009-05-19 Thread Eric Bouer
Hello List. I'm new to camel and I looked over the Quartz component page in the documentation. I couldn't find any usefull example for using quartz jobs. I can see that I'm able to set job.name in the URI but I don't see where and how I can specify a job itself to a trigger. Are there any example

Re: Looking for quartz Job examples.

2009-05-20 Thread Eric Bouer
You guys are very helpful to others :) So I guess I asked something wrong Or that there are no examples anywhere. In that case, Could you please demonstrate how to pass a job to quartz? I'm using the so far well done 2.0-M1 Eric. Eric Bouer wrote: > > Hello List. > I'm

Camel 2.0 JMS options are not working

2009-05-31 Thread Eric Bouer
Hello. Can you please help me figure out why camel 2.0 JMS options on http://camel.apache.org/jms.html this page (the highlighted) are not working in my project ? I tried jmsMessageType , jmsKeyFormatStrategy and few others. This is how I configure my endpoint: ConnectionFactory connectionFa

Re: Camel 2.0 JMS options are not working

2009-05-31 Thread Eric Bouer
.0m1 release. > You can wait for 2.0m2 or try the SNAPSHOT releases. > > Details about snapshot at the downloads page how to get it using > maven, or where to find a .zip with the entire release. > http://camel.apache.org/download.html > > > On Sun, May 31, 2009 at 12:27

Understanding MulticastDiscoveryAgentNotifier behavior.

2009-06-05 Thread Eric Bouer
Hello list. I'm trying the following code to test multicast capabilities of camel+activeMQ. I found out that a new thread is started for each new message I send, but the thread is staying alive for the whole program lifetime. The number of live "multicast discovery agent notifier" threads scales u

Re: Understanding MulticastDiscoveryAgentNotifier behavior.

2009-06-05 Thread Eric Bouer
> > On Fri, Jun 5, 2009 at 11:27 AM, Eric Bouer wrote: >> >> Hello list. >> I'm trying the following code to test multicast capabilities of >> camel+activeMQ. >> I found out that a new thread is started for each new message I send, but >> the

Consuming advisory messages in camel.

2009-06-11 Thread Eric Bouer
Hello. I can't figure out how to consume advisory messges in camel. Using simple java code I would use AdvisoryConsumer that can provide me details about the advisory message (Advisory type). Simply consuming from("activemq:topic:ActiveMQ.Advisory.Producer.Queue.MyQueue").to(someprocess()) doesn't

Re: Consuming advisory messages in camel.

2009-06-16 Thread Eric Bouer
, I'm wondering if there is another more integrated way of doing so. Claus Ibsen-2 wrote: > > On Thu, Jun 11, 2009 at 4:43 PM, Eric Bouer wrote: >> >> Hello. >> I can't figure out how to consume advisory messges in camel. >> Using simple java code I would

Re: JMSReplyTo in 2.0-M2

2009-06-29 Thread Eric Bouer
https://issues.apache.org/activemq/browse/CAMEL-1773 unfortunately I get the same behavior on M1 How did you progress Thomas ? Claus Ibsen-2 wrote: > > Hi Thomas > > To help with this I would like you to create a simple unit test / > route that you use the I can use as base for an unit test to

Still problems with InOut JMS

2009-07-06 Thread Eric Bouer
I finally had time to try again the JMSReplyTo issue. Going back to https://issues.apache.org/activemq/browse/CAMEL-1773 https://issues.apache.org/activemq/browse/CAMEL-1773 . I understand that I can set JMSReplyTo header of InOnly message and also send it with preserveMessageQos=true. but then c

Re: Still problems with InOut JMS

2009-07-07 Thread Eric Bouer
ows Exception { >>                                exchange.getIn().setBody("What's your >> name"); >> >> exchange.getIn().setHeader("JMSReplyTo", "nameReplyQueue"); >>                            } >>                        }) >>

Re: Camel 2.0-M3 swalllowing exceptions?

2009-08-06 Thread Eric Bouer
I'm having a similar problem. I have a route that does some incorrect casting of body message. M2 Throws ClassCastException wile M3 silently abort the operation and drops the message. when I step inside the M3 code with the debugger I can see that it's doing some exception handling but shows noth

Replies are not consumed from reply queue.

2009-08-25 Thread Eric Bouer
Hello. I'm sending messages with InOut pattern to a JMS topic and set the replyTo to a predefined queue. Most of the time everything works fine but... I have a suspicious situation that under certain conditions, camel wont read replies from that queue and fail with ExchangeTimedOutException. I can

Re: Replies are not consumed from reply queue.

2009-08-26 Thread Eric Bouer
upted: " + e, e); > } > } catch (TimeoutException e) { > if (LOG.isDebugEnabled()) { > LOG.debug("Future timed out: " + e, e); > } > } > > Willem > > Eri

Cahnging endpoint from SEDA to direct causes ClassCastException

2009-09-17 Thread Eric Bouer
Hello. I recently changes some routes to use SEDA instead of direct and since then started to get ClassCastException on the following code in my processor. JmsMessage in = (JmsMessage) exchange.getIn(); ActiveMQTextMessage activeMQTextMessage = (ActiveMQTextMessage) in.getJmsMessage();

explicitly setting replyTo doesn't scale with .threads() and JMS cache.

2009-10-21 Thread Eric Bouer
Hello. In order to optimize my InOut throughput I added explicit replyTo on my JMS endpoint. This doesn't seems to be well behaving with camel threads and spring JMS caching. The following test case shows the problem. remove the explicit replyTo and everything works fine. your comments are welcom

Recipient List with optional destinations.

2010-05-04 Thread Eric Bouer
Hello. I have a situation where I need to use dynamic router that should route the messages to endpoints that may or may be not exist. The problem is that camel will throw a NoSuchEndpointException since it's trying to resolve that destination name. I would like it just to skip that endpoint and m

Re: Recipient List with optional destinations.

2010-05-11 Thread Eric Bouer
hanks. willem.jiang wrote: > > How about the ErrorHandler[1]? you can use OnException[2] to check this > kind of NoSuchEndpointException, and skip the route part. > > [1]http://camel.apache.org/error-handler.html > [2]http://camel.apache.org/exception-clause.html > > Willem >

Should I use camel+netty for TCP streaming proxy?

2010-05-13 Thread Eric Bouer
Hello. I would like to estimate the effort and possibility to use camel-netty to proxy TCP streams from one listening port to another. My route should look like this: from("netty:tcp://0.0.0.0:?decoders=#decoders&sync=true") .to("netty:tcp://foo:?encoders=#myencoders&sync=true") The kind

Re: Recipient List with optional destinations.

2010-05-20 Thread Eric Bouer
amel 2.3-SNAPSHOT to verify the fixing? > > [1] https://issues.apache.org/activemq/browse/CAMEL-2710 > > Willem > Eric Bouer wrote: >> Hi. >> You're right about that, I added errorhandler that just suppressed the >> warrning. >> But throwing an exception (fi