Re: ActiveMQ composite destination producer

2013-08-07 Thread Marco Crivellaro
Thanks The example I reported though is properly pushing 2 messages on the broker though. So it seems to work but not supporting a mix of topic and queue in the list. correct me if I am wrong but using multicast is not exactly the same thing of using composite destinations, if I've understood

Re: How to Pause Quartz Componenent

2013-08-07 Thread Claus Ibsen
Hi Yeah this is a bug https://issues.apache.org/jira/browse/CAMEL-6614 You can use stop/start instead. On Tue, Jul 23, 2013 at 11:43 AM, Dayakar daya.kond...@gmail.com wrote: Hi, I am using Quartz Component which run Daily at 20:00 I configured it as

Re: camel - Activemq strange behaviour

2013-08-07 Thread kiranreddykasa
Hi Thanks a lot. So we should have unique queue names in cluster environment, if we are using replyToType as exclusive or temporary queues can be used. - Regards kiran Reddy -- View this message in context:

Using camel route for parsing a csv file

2013-08-07 Thread vkarkhanis
Hello, We have a simple scenario of reading a CSV file and persisting the records into database. We have following route configured for the same: routeContext id=persistIRDCF1 xmlns=http://camel.apache.org/schema/spring; route id=IRD_CF1_LN_FILE_BATCH from

Unable start Camel bundle deployed on OSGi in EAP 6.1

2013-08-07 Thread rajvaida
Hi I have made following bundle. MML-WS-Gateway-1.0.0-SNAPSHOT.jar http://camel.465427.n5.nabble.com/file/n5736911/MML-WS-Gateway-1.0.0-SNAPSHOT.jar After deploying this to OSGi of EAP 6.1, I am always getting following error. Please could you help me? / MSC01: Failed to start service

Re: Dynamic xsl with custom uri resolver

2013-08-07 Thread ericsodt
From what I am seeing, you can specify the custom resolver within the header {code} .setHeader(CamelXsltResourceUri,simple(xslt:http://localhost:8080/path/to/template?*uriResolver=#myResolver*) {/code} and it gets exercises at run time. When I place break points within my resolver and execute

Unable to use move,movefailed and donefilename with consumer template endpoint Uri

2013-08-07 Thread skumar
Hi, I have gone through lots of regarding the issue and came to know if I use consumer.receiveBody() I can move the file but when I am using it I am getting error like: Exception while consuming the locates file:null :Failed to resolve endpoint: file:///home/... Failed to resolve endpoint:

Re: Flatpack and aggregation

2013-08-07 Thread Tom.Fornoville
Hi Zemian, Thanks for putting me on the right track with the idempotentConsumer! Since Flatpack puts the records in a Java Map in the Body I had to do a convertTo and ended up with the following: bean id=organisationMemoryRepository

Lots of ActiveMQMessageConsumer with selector JMSCorrelationID='CamelDummyJmsMessageSelector'

2013-08-07 Thread tnk
Hello, after about 1 day usage, I got a strange situation - there are lot of ActiveMQMessageConsumers created (~640k) with selector JMSCorrelationID='CamelDummyJmsMessageSelector'. All consumer objects use around 1GB heap memory. Camel route is quite simple: route id=...

Re: Unable to use move,movefailed and donefilename with consumer template endpoint Uri

2013-08-07 Thread Claus Ibsen
Hi Read the javadoc of the consumer template, it tells you what to do. On Wed, Aug 7, 2013 at 3:17 PM, skumar sku...@stonewain.com wrote: Hi, I have gone through lots of regarding the issue and came to know if I use consumer.receiveBody() I can move the file but when I am using it I am

Re: Lots of ActiveMQMessageConsumer with selector JMSCorrelationID='CamelDummyJmsMessageSelector'

2013-08-07 Thread Claus Ibsen
Try a newer Camel version as this is fixed in a later release On Wed, Aug 7, 2013 at 3:48 PM, tnk jus...@gmail.com wrote: Hello, after about 1 day usage, I got a strange situation - there are lot of ActiveMQMessageConsumers created (~640k) with selector

Re: Lots of ActiveMQMessageConsumer with selector JMSCorrelationID='CamelDummyJmsMessageSelector'

2013-08-07 Thread tnk
Thanks for quick reply. The problem is, I can't update camel version because the system is running is production with a lot bundles. Upgrading to new camel requires a lot of refactoring due to api changes... Is there any workaround (other than upgrading camel) possible in this case? -- View

Re: Using camel route for parsing a csv file

2013-08-07 Thread jduncan
It looks like you may also need to add the apache commons-csv jar to your class path. This is one of the dependencies of the camel-csv jar: org.apache.servicemix.bundles/org.apache.servicemix.bundles.commons-csv Jared -- View this message in context:

Re: Lots of ActiveMQMessageConsumer with selector JMSCorrelationID='CamelDummyJmsMessageSelector'

2013-08-07 Thread Claus Ibsen
Use temporary queues for the replies instead of the shared queue. Or patch the camel-jms with the bug fix yourself. On Wed, Aug 7, 2013 at 4:02 PM, tnk jus...@gmail.com wrote: Thanks for quick reply. The problem is, I can't update camel version because the system is running is production with

Re: Lots of ActiveMQMessageConsumer with selector JMSCorrelationID='CamelDummyJmsMessageSelector'

2013-08-07 Thread tnk
Is this problem related to recipientList? Or it is general issue with camel request/reply over jms? I haven't noticed this behaviour in other routes with InOut pattern over amq queue. Do you have any link to jira issue or other pages where this problem is described? Thank you. -- View this

Re: Using camel route for parsing a csv file

2013-08-07 Thread Hilderich
sub project camel-csv has the following dependency in its POM: *dependency groupIdorg.apache.servicemix.bundles/groupId artifactIdorg.apache.servicemix.bundles.commons-csv/artifactId version${commons-csv}/version /dependency* There you can find there the class

Re: camel rabbitmq

2013-08-07 Thread dalewking
I ran into this as well and can be worked around by adding this between your from and to: .setHeader(RabbitMQConstants.EXCHANGE_NAME).constant(A) -- View this message in context:

Re: camel - Activemq strange behaviour

2013-08-07 Thread Christian Posta
On Wed, Aug 7, 2013 at 3:08 AM, kiranreddykasa kirankuma...@fss.co.inwrote: Hi Thanks a lot. So we should have unique queue names in cluster environment, if we are using replyToType as exclusive This is correct. The camel docs explicitly say not to use Exclusive in your type of

Re: ActiveMQ composite destination producer

2013-08-07 Thread Christian Posta
This might be what you're looking for. Check out Composite Destination section on this wiki: http://activemq.apache.org/virtual-destinations.html On Wed, Aug 7, 2013 at 1:36 AM, Marco Crivellaro marco.cr...@gmail.comwrote: Thanks The example I reported though is properly pushing 2

Re: Lots of ActiveMQMessageConsumer with selector JMSCorrelationID='CamelDummyJmsMessageSelector'

2013-08-07 Thread Christian Posta
Take a look here: https://issues.apache.org/jira/browse/CAMEL-2740 On Wed, Aug 7, 2013 at 7:24 AM, tnk jus...@gmail.com wrote: Is this problem related to recipientList? Or it is general issue with camel request/reply over jms? I haven't noticed this behaviour in other routes with InOut

Re: Unit of Work Scope and direct/SEDA/vm components

2013-08-07 Thread Christian Posta
Could you also do the following? from(...)..to(vm:name).process(new Processor() { public void process(Exchange exchange) { exchange.getUnitOfWork().done(); } }); On Tue, Aug 6, 2013 at 7:11 AM, Scott Parkerson sc...@parkerson.net wrote: Bilgin, Thank you -- that's what I

Limit concurrency to messages with different headers

2013-08-07 Thread bocamel
I need to process orders from multiple companies and then send them out. The logic for processing is almost identical but I need to send all messages from a company out in the exact sequence as they are received.Therefore, I would like to have concurrency but need to apply concurrency only

Re: Limit concurrency to messages with different headers

2013-08-07 Thread Christian Posta
Can you use content based router to two endpoints: seda with one thread vs seda with multiple threads? and then use resequencer to put the messages back in order? On Wed, Aug 7, 2013 at 12:24 PM, bocamel johnz...@gmail.com wrote: I need to process orders from multiple companies and then send

Re: Unable to use move,movefailed and donefilename with consumer template endpoint Uri

2013-08-07 Thread skumar
Claus, I have gone through the section Timer based polling consumer at http://camel.apache.org/polling-consumer.html as I am using a timer in my route defnition. I try to follow it but still getting the same error.It seems some thing is wrong with the endpoint itself String

Re: Using camel route for parsing a csv file

2013-08-07 Thread Christian Müller
camel-csv cmueller$ mvn dependency:tree [INFO] Scanning for projects... [INFO] [INFO] [INFO] Building Camel :: CSV 2.11.0 [INFO] [INFO] [INFO] ---

smtp option contentType=text/html has no effect

2013-08-07 Thread Hilderich
Hello folks! We are using Camel 2.10.4. Before sending an email I create the html email message via Apache Velocity. The smtp component has the option contentType and that's why I have set it to text/html. However this configuration has no effect and I receive the email as plain text. After I

Creating then starting a JMS consumer around another component

2013-08-07 Thread markgize
We are interested in Camel but have a specific startup sequence that we need to follow: 1) Open a JMS topic consumer for our updates, but, do not get any of the messages. 2) Query our database and build a state of the world 3) Start to get the update messages from the consumer we opened We

camel-rabbitmq producer is not including the body

2013-08-07 Thread dalewking
Trying to consume from rabbitmq using the camel-rabbitmq component and the problem is the body of the message is not being passed down the line. Debugging and looking at the source, I see that in RabbitMQConsumer.RabbitConsumer.handleDelivery that the body is being passed into the method, but

Re: Creating then starting a JMS consumer around another component

2013-08-07 Thread John D. Ament
Hi, Why isn't 2,1,3 possible? Why not setup your consumer before you start up your camel context? On Wed, Aug 7, 2013 at 7:22 PM, markgize mark.gizejew...@pimco.com wrote: We are interested in Camel but have a specific startup sequence that we need to follow: 1) Open a JMS topic consumer for

Question about ZooKeeper APIs

2013-08-07 Thread bonnahu
Hi all, I can see ZooKeeper APIs are available in Camel. Is there any good examples for the ZooKeeper APIs? thanks Lei -- View this message in context: http://camel.465427.n5.nabble.com/Question-about-ZooKeeper-APIs-tp5736960.html Sent from the Camel - Users mailing list archive at

Re: camel-rabbitmq producer is not including the body

2013-08-07 Thread Willem jiang
Hi, Thanks for reporting it. I just filled a JIRA[1] and committed a fix for it. [1]https://issues.apache.org/jira/browse/CAMEL-6617 -- Willem Jiang Red Hat, Inc. FuseSource is now part of Red Hat Web: http://www.fusesource.com | http://www.redhat.com Blog: http://willemjiang.blogspot.com

Re: Question about ZooKeeper APIs

2013-08-07 Thread Willem jiang
Hi, Did you have a chance to check out the Camel-ZooKeeper document[1]? [1]http://camel.apache.org/zookeeper.html -- Willem Jiang Red Hat, Inc. FuseSource is now part of Red Hat Web: http://www.fusesource.com | http://www.redhat.com Blog: http://willemjiang.blogspot.com

Re: Question about ZooKeeper APIs

2013-08-07 Thread Christian Posta
May want to also peek at the unit tests: https://git-wip-us.apache.org/repos/asf?p=camel.git;a=tree;f=components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper;h=633ed267f43b43f3d46789236ec5583f4ea7be93;hb=HEAD On Wed, Aug 7, 2013 at 7:54 PM, Willem jiang