Camel/ActiveMQ Reuqest/Reply and Transactions

Hello, I have some basic questions on Camel/ActiveMQ transactions with request/reply jms endpoints/ Have the following route. ( i basically took the example request/reply jms example from the Camel in action book and springiified). When I have the *transactionManager *attribute pf the ActiveMQ co

Camel/ActiveMQ RequestReply Transaction Question

Hello, I have some basic questions on Camel/ActiveMQ transactions with request/reply jms endpoints/ Have the following route. ( i basically took the example request/reply jms example from the Camel in action book and springiified). When I have the transactionManager attribute pf the ActiveMQ comp

Camel Custom Splitter Question

Hello, I want to able be able to write a custom splitter such that: 1) A message with collection is broken down into individual message(exchange) 2) Based on the content of the message add a Message header. 3) Aggregate the split messages using the message header as the strategy. The only way I

Camel complex route split/aggregate/complex Correlation question

Hello, I am working with millions of rows of Cancer records. A cancer site (Colon, Prostate) is identified by a field called PrimarySite. A given Cancer site can have one of many values (A colon can have multiple individual sites (say C01 to C10). My intend is to load 500 records of Cancer record

Re: AW: Camel Custom Splitter Question

Hello Jan, Thank you very much for your reply. But this still does not solve my problem. The collection of Cancer records loaded from the DB has records from various cancer sites (Like Colon, Breast, Prostate ). The type of record is "*CancerRecord*" and the filed *PrimarySite *identifies the Cance

Camel Testing -JTA java.sql.SQLSyntaxErrorException: ORA-02049: timeout: distributed transaction waiting for lock

Hello, I am writing some Unit tests to test my routes which are configured to use JTA and the routes work great! But I want to clean the target table before I start my tests, But I am getting the following Exception My Test file looks like this! Been stuck on this for a while. Any ideas plea

Re: Camel Testing -JTA java.sql.SQLSyntaxErrorException: ORA-02049: timeout: distributed transaction waiting for lock

Hello, I found this section *Integration Testing with Spring* in the following link, http://camel.apache.org/book-pattern-appendix.html and I followed this example from the above link. https://github.com/rajivj2/example2/blob/master/src/test/

Camel JMS XA Transaction with Bitronix - Problem/Question

Hello, I have configured JTA transactions using Bitronix and I have used this configurations for many years for testing my applications outside the J2EE container. Now I am trying to test a simple JMS route using "transacted" attribute as follows! I am getting the following error! *bitronix.

Camel JPA/JTA/Jboss - You cannot commit with autocommit set

Hello, I have a simple route with Hibernate/JPA. The application is running inside the JBoss and using the JTA Transaction manager. I keep getting the error when the route executes. I didn't face this issue when I ran the same out side of JBoss but with Bitronix JTA. I am not even sure if its a Ca

ActiveMQ - java.io.IOException: Transport scheme NOT recognized: [tcp]

Hello, I am facing a strange error when I use ActiveMQ in my routes where ActiveNQ is configured as a RA. I am having a real hard time having ActiveMQ connection factory working as part of the XA Transaction. I have configured ActiveMQ as a Wildfly xa resource and I can see that it is configured o

Re: Hlep Please - TransactionErroHandler/retry/DLC issues. Stuck

Hello, *Please note that I am Using JTA Transaction Manager* (Bitronix standalone) and JBoss server. Thanks Matt - Thanks Matt G. Madhavan -- View this message in context: http://camel.465427.n5.nabble.com/Hlep-Please-TransactionErroHandler-retry-DLC-issues-Stuck-tp5764363p5764366.html Sen

Hlep Please - TransactionErroHandler/retry/DLC issues. Stuck

Hello, I have been having few issues with my TransactionErrorHandler. It does not seem to work as expected. More than like likely I am not configuring properly. I want to handle the retry and the DLC at the application level (Camel level) and not at the Transport level (AMQ). It looks for retry an

Re: Hlep Please - TransactionErroHandler/retry/DLC issues. Stuck

Hello, Anyone out there please? Matt - Thanks Matt G. Madhavan -- View this message in context: http://camel.465427.n5.nabble.com/Hlep-Please-TransactionErroHandler-retry-DLC-issues-Stuck-tp5764363p5764782.html Sent from the Camel - Users mailing list archive at Nabble.com.

ActiveMQ-ProducerTemplate, not getting the response back! Any missing cobfiguration

Hello, Bear with me am a Newbie! /The following is my route config: / http://camel.apache.org/schema/blueprint";> Camel In-Bound Route / My java code is:/ ProducerTemplate template = this.camelContext.createProducerTemplate(); Transfer

Camel for Karaf 2.0

Hello, Due my cleint's target platform which is IBM WAS 7.1, I'm stuck with Aries 0.1. I want to develop and test my app in Karaf before deploying testing and deploying to WAS since Karaf increases our development productivity many fold. So I'm stuck with Karaf 2.0 due to Aries 0.1. I would like

Seamlessly switching from Felix and Equinox - data folder

Hello, My understanding is that when I switch OSGi runtime the data folder becomes stale and I have to start delete the data folder content and start installing my features and bundles again. Can I preserve the state of my Karaf between OSGi runtime switches? Will save some time! Thanks Matt --

Help creating a route amq1-->bean-->amq2 - with timeouts

Hello, I have been struggling recently to define a simple rout! I want the messages sent to a JMS (AMQ) to be sent to a method of a bean and then reply sent to another queue. Also the bean may take more than 20 secs to process. So I would like to add a large timeout value as well. This is what

Re: Help creating a route amq1-->bean-->amq2 - with timeouts

Hi Christian, Thank you very much for the reply! I appreciate it. I have couple of more questions please! / I send receive the message as follows:/ Transfer reply = (Transfer) template.requestBody("activemq:TestHarness.A", transfer); on the oneMessage method of the bean, I think I should just re

IBM WAS - Aries 0.1 and Camel

Hello, I have been struggling with this issue for a while and any help/insights will be greatly appreciated! I'm struck with WAS v7 and hence Aries 0.1. And I want to replace the SCA bindings (IBM's Tuscany) with Camel as it seems to be lot more easy to set up and am awesome product. I have two i

Re: IBM WAS - Aries 0.1 and Camel

Hi Claus, No we are using EBA - and using SCA(Tuscany) as an Asset. I would like to replace SCA with Camel. Any pointers regarding this will be greatly appreciated. Thanks Matt -- View this message in context: http://camel.465427.n5.nabble.com/IBM-WAS-Aries-0-1-and-Camel-tp5014977p5029982.html

Basic JMS to bean In/Out Router Question

Hello, I have been in out with this question for a while - Been pulled in different directions last few months - My apologies about it! Been spending some time on the Camel Book, starting to understand some basic concepts. I want to build a route that reads from a queue A invokes a method on a be

Re: Basic JMS to bean In/Out Router Question

Hi Claus, I still cannot get the this simple scenario working - Shame on me! Any assistance will be appreciated. I have the following route in the configure (@override) method of my test class. /from("jms:validate?*replyTo=validateResul*t").bean(ValidatorBean.class).to("jms:validateResult");/

Re: Basic JMS to bean In/Out Router Question

Hello, Sorry about my ramblings above! I figured this out (Man was so simple!) This thread helped me! http://camel.465427.n5.nabble.com/Request-Reply-using-a-predefined-reply-queue-td470371.html /This is my Route:/ * from("jms:validate?replyTo=validateResult").bean(ValidatorBean.cla

JMS Queue to Bean To JMSQueue - Turn around time

Hello, *This is my Route:* from("jms:validate?replyTo=validateResult").bean(ValidatorBean.class); *Sending a message as follows:* template.sendBody("jms:validate", "My Text Message"); *Receiving the replied message as follows:* Endpoint endpoint = context.getEndpoin

Re: Camel JMS Request/Reply with Websphere

Hi Mark, I'm in the process of doing the same thing like you are with WAS. Can you please share your configuration with me in more detail please? I would like to see the Java DSL and other details if possible! Thanks in advance! Matt -- View this message in context: http://camel.465427.n5.nabb

Really Basic Question on ServiceMix, Karaf and Camel

Hello, I'm just a little confused explaining how all these frameworks fit together. /My understanding is:/ ServiceMix is ESB that used Karaf as its OSGi Framework(with Felix/Equinox) and used Camel for routing messages. Its preferred JMS implementation being ActiveMQ. Am I missing something here?

Re: Really Basic Question on ServiceMix, Karaf and Camel

Hi Brian, Thank you very much for your reply. Does ServiceMix itself have any ot its own technology at all besides packaging other technologies? Thanks Matt -- View this message in context: http://camel.465427.n5.nabble.com/Really-Basic-Question-on-ServiceMix-Karaf-and-Camel-tp5443239p5445148.h

Camel Shutdown does not shutdown ActiveMQ

Hello, When I try to shutdown a Spring boot/Camel application for some reason the activemq connections are not shutdown. I am shutting down as follows. But as can be seen from Eclipse the application does not shutdown.