Mock Endpoint behavior on sleep

2013-05-23 Thread sharad.gokl...@in.airtel.com
Hi, I am slightly tweaking the code example of chapter 6 of camel in action (code enclosed below). On adding Thread.sleep(), the subsequent assertion is failing: java.lang.AssertionError: mock://quote Body of message: 0. Expected: Camel rocks but was: null Any clue on why this is happening?

Re: Mock Endpoint behavior on sleep

2013-05-23 Thread Claus Ibsen
Hi You should set your expectations *first* on the mock endpoint, *before* you send messages into Camel. See figure 6.3 in the book. On Thu, May 23, 2013 at 10:25 AM, sharad.gokl...@in.airtel.com sharad.gokl...@in.airtel.com wrote: Hi, I am slightly tweaking the code example of chapter 6 of

prevent CamelContext from shutting down in blueprint

2013-05-23 Thread Ioan Eugen Stan
Hello, I'm using Camel 2.11.0 under Karaf 2.3.1. I'm creating the camel context via blueprint and Ican't figure out how to prevent it from shutting down instantly after starting. I've pasted some trimmed log messages. You can see that the context shuts down right after startup without throwing

Re: prevent CamelContext from shutting down in blueprint

2013-05-23 Thread Achim Nierbeck
Maybe turning on debug level in the logging will give you a better reason why the camel context is destroyed right after startup. This usually happens if you have something wrong in your route ... regards, Achim 2013/5/23 Ioan Eugen Stan stan.ieu...@gmail.com Hello, I'm using Camel 2.11.0

MailComponent/MailConsumer misses Mails

2013-05-23 Thread cgiera
Hello, I'm facing strange problems when consuming mails from a cyrus mail server. Some mails were not processed but appear as SEEN in the mailbox. I've added the mail debug option to the route and I was pretty confused when analyzing the log: First poll is quite normal: 14 new mails, 14 get

Re: prevent CamelContext from shutting down in blueprint

2013-05-23 Thread Ioan Eugen Stan
Hello Achim, Setting logging to DEBUG helped more than expected. The Context doesn't shut-down anymore. It's a synchronization issue which will be a a joy to debug. Have a great day,

Re: prevent CamelContext from shutting down in blueprint

2013-05-23 Thread Ioan Eugen Stan
Hello Martin, It's simple: Just after the Camel Context start it shuts down, gracefully. I've pasted the logging with debug [1]. If it helps. [1] https://paste.apache.org/cnfW

TypeConversionException: Error during type conversion

2013-05-23 Thread camelrider
Hi, I have a server application which receives a list of messages (POJO) from the client and then processes them before enqueueing them to ActiveMQ. The error is as follows My spring configuration is: The SendMessageProcessor implementation: I use a splitter to split the multiple

Re: Upgrade Camel 2.10.1 - 2.11.0 - Camel keeps restarting

2013-05-23 Thread Martin Stiborský
Not yet - I hasn't spent too much time on this and we postponed Camel 2.11 upgrade right now. I'll check debug log of camel and try to find the problem there. It seems I'm not alone on this :) http://camel.465427.n5.nabble.com/prevent-CamelContext-from-shutting-down-in-blueprint-td5733004.html

Re: prevent CamelContext from shutting down in blueprint

2013-05-23 Thread Martin Stiborský
yes, it is doing the same to me :) - http://camel.465427.n5.nabble.com/Upgrade-Camel-2-10-1-2-11-0-Camel-keeps-restarting-td5731854.html I'll try to find out more what is happening there... On Thu, May 23, 2013 at 1:53 PM, Ioan Eugen Stan stan.ieu...@gmail.com wrote: Hello Martin, It's simple:

Re: Upgrade Camel 2.10.1 - 2.11.0 - Camel keeps restarting

2013-05-23 Thread Raul Kripalani
It could be an issue with the way you deploy your bundles. If you drop them in the deploy/ directory, and you happen to deploy libraries that fulfill optional imports elsewhere, the OSGi framework could force a refresh of the entire bundle set. Hence justifying the observed behaviour to some

Problem in mqtt Component

2013-05-23 Thread Jinesh M.K
Hi, I have some problem with mqtt end point using spring DSL. Here my route definition camel:route camel:from uri=mqtt:foo?host=tcp://myhost:1883amp;subscribeTopicName=test/# / camel:to uri=mqtt:bar?host=tcp:/myhost:1883amp;publishTopicName=test1/test /

Re: Upgrade Camel 2.10.1 - 2.11.0 - Camel keeps restarting

2013-05-23 Thread Martin Stiborský
Hi! We are using features for deployment (https://cwiki.apache.org/KARAF/46-provisioning.html). I did a quick test with Camel 2.11 and Karaf 2.3.1, completely fresh installation and this I have there some dependencies troubles, like missing osgi.wiring.package=org.apache.aries.util and few

Re: Problem in mqtt Component

2013-05-23 Thread Robert Davies
Hi Jinesh, which MQTT broker are you running and which version ? It looks like the client isn't able to connect for some reason. Also - which version of Apache Camel are you using ? thanks, Rob On 23 May 2013, at 13:42, Jinesh M.K mkjin...@gmail.com wrote: Hi, I have some problem with

Custom component for weird legacy format

2013-05-23 Thread Frank Ertl
Hi everybody, we have to implement a route that listens on a defined http-port and receives a message with a very strange legacy format. Partly XML, partly TLV (tag-length-value). I wonder what would be the best option to overcome this mess. Writing a custom component that could work as a

Re: MailComponent/MailConsumer misses Mails

2013-05-23 Thread Christian Müller
Camel 2.6.0 is a bit old and not supported anymore. Do you have a chance to try a newer version (e.g. 2.11.0) and check whether it behaves in the same way!? Best, Christian Sent from a mobile device Am 23.05.2013 11:01 schrieb cgiera christoph.gi...@mic-cust.com: Hello, I'm facing strange

Marshal with quote in CSV

2013-05-23 Thread Jean Francois LE BESCONT
Hi, I have found a strange behavior with the bindy in CSV. It is said in the doc that : Notice that if you want to marshal from Object to CSV and use quotes, then you need to specify which quote character to use, using the quote attribute on the @CsvRecord as shown below: @CsvRecord( separator

Re: Custom component for weird legacy format

2013-05-23 Thread Lutz Horn
Hi, Am Do, 23. Mai 2013, um 15:56, schrieb Frank Ertl: just to write a new TypeConverter and call convertToType after receiving the message via the jetty-component? This should not be too difficult. Parsing the Exchange body sounds like the difficult part, not receiving it via HTTP. You could

Problem in mqtt Component

2013-05-23 Thread Jinesh M.K
Hi, I have some problem with mqtt end point using spring DSL. Here my route definition camel:route camel:from uri=mqtt:foo?host=tcp://myhost:1883amp;subscribeTopicName=test/# / camel:to uri=mqtt:bar?host=tcp:/myhost:1883amp;publishTopicName=test1/test /

Assigning a name to a thread in Camel

2013-05-23 Thread Edwin
Hi Folks, I have multiple Quartz driven routes in an application. When viewing the application log files, it can be difficult to determine which route the currently executing threads belong to i.e DefaultQuartzScheduler-camel_Worker-1 DefaultQuartzScheduler-camel_Worker-2 ... I'm wondering is

Re: Custom component for weird legacy format

2013-05-23 Thread Raul Kripalani
Hi Frank, By no means do you need to write a custom component! Camel has a lot of features to help you in processing and/or transforming the message. First of all, take a look at our Data Formats [1] and see any can help you digest the message. Of special relevance in your case are Bindy,

Why doesn't the stub component throw exceptions in tests

2013-05-23 Thread dancerjohn
I am writing a test for my error handling. The route I am testing uses JMS and therefore has URL properties that are not compatible with the direct component. The way I have it set up is that I pass the following to the Route Builder (jms:queue:myqueue) and then it adds the additional URL

Re: Camel Quartz and JobStore

2013-05-23 Thread garrydias
JBoss 7 does not have Quartz in its modules. Is this problem related to this issue https://issues.apache.org/jira/browse/CAMEL-6067? thanx -- View this message in context: http://camel.465427.n5.nabble.com/Camel-Quartz-and-JobStore-tp5732853p5733043.html Sent from the Camel - Users mailing

Mulitcast and stopOnexception

2013-05-23 Thread crmanoj
Hi, I have a scenario using Multicast and I want to stop the execution if any one of the routes in multicast fails, So I used stoponException along with multicast. Though I have appropriate error handlers written I end up receiving 'org.apache.camel.CamelExchangeException: *Parallel processing

aggregator: dynamic completion size

2013-05-23 Thread javamonkey79
It seems that the completionSize attribute of the aggregator will make up the difference if there are no more messages. I'd like to be able to do something like: aggregate strategyRef=myAggregationStrategy completionSize=500

Re: Custom component for weird legacy format

2013-05-23 Thread Willem jiang
I don't think we need to write a customer HTTP binding this time, writing a custom Data Format should be enough. If you have some special HTTP header need to deal with, you may consider to write that HTTP binding. -- Willem Jiang Red Hat, Inc. FuseSource is now part of Red Hat Web:

Re: Problem in mqtt Component

2013-05-23 Thread Willem jiang
Hi Did you push some message to the topic which the route is subscribed? Can you add some log between your first route from and to endpoints? -- Willem Jiang Red Hat, Inc. FuseSource is now part of Red Hat Web: http://www.fusesource.com | http://www.redhat.com Blog:

Re: Sftp component problem

2013-05-23 Thread emmanuel
One precision : I use 2.8.4 camel version -- View this message in context: http://camel.465427.n5.nabble.com/Sftp-component-problem-tp5733034p5733035.html Sent from the Camel - Users mailing list archive at Nabble.com.

Sftp component problem

2013-05-23 Thread emmanuel
Hello, I use sftp component to transfer file on a local directory : sftp://${login}@${host}:${port}/${path}?localWorkDirectory=${DATA_PATH}/LOCAL/WRKamp;delay=${delay}amp;knownHostsFile=${transfer.knownHosts}amp;privateKeyFile=${transfer.privateKeyFile}amp;filter=#EP_IN_FILTERamp;delete=true I

Re: Problem in mqtt Component

2013-05-23 Thread Jinesh M.K
Hi Jiang, Thanks for rthe eply On 24 May 2013 07:38, Willem jiang willem.ji...@gmail.com wrote: Hi Did you push some message to the topic which the route is subscribed? Yes, using some Java MQTT client Can you add some log between your first route from and to endpoints? I done like this

Re: aggregator: dynamic completion size

2013-05-23 Thread Claus Ibsen
Hi Yeah read the docs http://camel.apache.org/aggregator2 You can use dynamic completion size / timeout etc. to trigger when you have 500 messages. On Fri, May 24, 2013 at 3:39 AM, javamonkey79 javamonke...@gmail.com wrote: It seems that the completionSize attribute of the aggregator will

Re: Assigning a name to a thread in Camel

2013-05-23 Thread Claus Ibsen
Hi Its really quartz that sets the thread names on its worker threads. I wonder if quartz have any api / hook we can use to let Camel use its thread name factory to give these threads better names? You may want to check the quartz api for that. An alternative is to use MDC logging

Re: MailComponent/MailConsumer misses Mails

2013-05-23 Thread Claus Ibsen
Hi You can try using maxMessagesPerPoll=10 or something to limit polling in too many mails. On Thu, May 23, 2013 at 11:01 AM, cgiera christoph.gi...@mic-cust.com wrote: Hello, I'm facing strange problems when consuming mails from a cyrus mail server. Some mails were not processed but appear

Re: Why doesn't the stub component throw exceptions in tests

2013-05-23 Thread Claus Ibsen
Hi Read the javadoc API on the producer template and the methods you use, eg sendBody vs requestBody. eg its about InOnly vs InOut messaging style. The eips http://camel.apache.org/event-message.html http://camel.apache.org/request-reply.html On Thu, May 23, 2013 at 8:15 PM, dancerjohn

Re: ConsumerTemplate for large number of files

2013-05-23 Thread Claus Ibsen
Hi Use maxMessagesPerPoll=1 when using the consumer template in the way you do. On Thu, May 23, 2013 at 6:03 PM, spilled_beverage grahamduck...@yahoo.co.uk wrote: I'm consuming from a directory which can contain a large number of files (currently trying with 1500). When using a basic route