Request - response using ProducerTemplate.requestBodyAndHeaders

Hi, I am trying to use the ProducerTemplate.requestBodyAndHeaders() method to send an EMS request message to an existing system. Map headers = new HashMap(); headers.put("form_name","trade_version"); headers.put("JMSCorrelationID", "ID:positionIVCRequest"); header

Re: Router with DSL

Great boday! Is it possible to communicate between two contexts. I m from J2EE background, in tomcat container, each web application has unique context. So we can deploy many application in the same container. Is it same in Camel ? Thanks again.. -- View this message in context: http://c

Re: Question about ZooKeeper APIs

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 wrote: > Hi, > > D

Re: Question about ZooKeeper APIs

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 (http://willemjiang.

Re: camel-rabbitmq producer is not including the body

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 (

Question about ZooKeeper APIs

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 Nabble.com

Re: Creating then starting a JMS consumer around another component

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 wrote: > 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

camel-rabbitmq producer is not including the body

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 noth

Creating then starting a JMS consumer around another component

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 cannot

smtp option contentType=text/html has no effect

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

Re: Using camel route for parsing a csv file

camel-csv cmueller$ mvn dependency:tree [INFO] Scanning for projects... [INFO] [INFO] [INFO] Building Camel :: CSV 2.11.0 [INFO] [INFO] [INFO] --- maven-

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

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 endPointUri="

Re: Limit concurrency to messages with different headers

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 wrote: > I need to process orders from multiple companies and then send them out. > The >

Limit concurrency to messages with different headers

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 whe

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

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 wrote: > Bilgin, > > Thank you -- that's what I expected, so I'll

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

Take a look here: https://issues.apache.org/jira/browse/CAMEL-2740 On Wed, Aug 7, 2013 at 7:24 AM, tnk 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 pattern over amq q

Re: ActiveMQ composite destination producer

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 wrote: > Thanks > > The example I reported though is properly pushing 2 messages on the broker >

Re: camel - Activemq strange behaviour

On Wed, Aug 7, 2013 at 3:08 AM, kiranreddykasa wrote: > 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 deployment: "A shared q

Re: camel rabbitmq

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: http://camel.465427.n5.nabble.com/camel-rabbitmq-tp5

Re: Using camel route for parsing a csv file

sub project camel-csv has the following dependency in its POM: * org.apache.servicemix.bundles org.apache.servicemix.bundles.commons-csv ${commons-csv} * There you can find there the class CSVConfig. -- View this message in context: http://camel.465427.n5.nabble.c

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

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 mess

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

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 wrote: > Thanks for quick reply. > The problem is, I can't update camel version because the system is running > is production with a lot bundles

Re: Using camel route for parsing a csv file

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: http://camel.465427.n5.nabble.com/Using-ca

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

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 thi

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

Try a newer Camel version as this is fixed in a later release On Wed, Aug 7, 2013 at 3:48 PM, tnk wrote: > Hello, > > after about 1 day usage, I got a strange situation - there are lot of > ActiveMQMessageConsumers created (~640k) with selector > JMSCorrelationID='CamelDummyJmsMessageSelector'.

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

Hi Read the javadoc of the consumer template, it tells you what to do. On Wed, Aug 7, 2013 at 3:17 PM, skumar 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 > getting error like

Lots of ActiveMQMessageConsumer with selector JMSCorrelationID='CamelDummyJmsMessageSelector'

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:

Re: Flatpack and aggregation

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: ... request.body["ACTION"] == "070" request.body["ORGANISATION"] This seems to work as e

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

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: Ch

Re: Dynamic xsl with custom uri resolver

>From what I am seeing, you can specify the custom resolver within the header {code} .setHeader("CamelXsltResourceUri",simple("xslt:http://localhost:8080///?*uriResolver=#myResolver*") {/code} and it gets exercises at run time. When I place break points within my resolver and execute this rout

Unable start Camel bundle deployed on OSGi in EAP 6.1

Hi I have made following bundle. 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

Using camel route for parsing a csv file

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: http://camel.apache.org/schema/spring";>

Re: camel - Activemq strange behaviour

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: http://camel.465427.n5.nabble.com/camel-Activemq-strange-behaviour-tp5736812p57

Re: How to Pause Quartz Componenent

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 wrote: > Hi, > > I am using Quartz Component which run Daily at 20:00 I configured it as > from("quartz://myGroup/myTimerName?cron=0+0+20+1/1+*+?+*")

Re: ActiveMQ composite destination producer

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 it