Return-Path: 
 <dev-return-37033-apmail-camel-dev-archive=camel.apache.org@camel.apache.org>
X-Original-To: apmail-camel-dev-archive@www.apache.org
Delivered-To: apmail-camel-dev-archive@www.apache.org
Received: from mail.apache.org (hermes.apache.org [140.211.11.3])
	by minotaur.apache.org (Postfix) with SMTP id EC0CBE52D
	for <apmail-camel-dev-archive@www.apache.org>;
 Mon, 31 Dec 2012 13:19:56 +0000 (UTC)
Received: (qmail 98426 invoked by uid 500); 31 Dec 2012 13:19:56 -0000
Delivered-To: apmail-camel-dev-archive@camel.apache.org
Received: (qmail 98074 invoked by uid 500); 31 Dec 2012 13:19:52 -0000
Mailing-List: contact dev-help@camel.apache.org; run by ezmlm
Precedence: bulk
List-Help: <mailto:dev-help@camel.apache.org>
List-Unsubscribe: <mailto:dev-unsubscribe@camel.apache.org>
List-Post: <mailto:dev@camel.apache.org>
List-Id: <dev.camel.apache.org>
Reply-To: dev@camel.apache.org
Delivered-To: mailing list dev@camel.apache.org
Received: (qmail 98033 invoked by uid 99); 31 Dec 2012 13:19:51 -0000
Received: from athena.apache.org (HELO athena.apache.org) (140.211.11.136)
    by apache.org (qpsmtpd/0.29) with ESMTP; Mon, 31 Dec 2012 13:19:51 +0000
X-ASF-Spam-Status: No, hits=2.0 required=5.0
	tests=SPF_NEUTRAL,URI_HEX
X-Spam-Check-By: apache.org
Received-SPF: neutral (athena.apache.org: 216.139.236.26 is neither permitted
 nor denied by domain of mihaistefanescu.md@gmail.com)
Received: from [216.139.236.26] (HELO sam.nabble.com) (216.139.236.26)
    by apache.org (qpsmtpd/0.29) with ESMTP; Mon, 31 Dec 2012 13:19:45 +0000
Received: from [192.168.236.26] (helo=sam.nabble.com)
	by sam.nabble.com with esmtp (Exim 4.72)
	(envelope-from <mihaistefanescu.md@gmail.com>)
	id 1TpfH3-0004Rz-Cy
	for dev@camel.apache.org; Mon, 31 Dec 2012 05:19:25 -0800
Date: Mon, 31 Dec 2012 05:19:25 -0800 (PST)
From: MichaelS <mihaistefanescu.md@gmail.com>
To: dev@camel.apache.org
Message-ID: <1356959965395-5724749.post@n5.nabble.com>
Subject: How to send a message to multiple endpoints in one transaction?
MIME-Version: 1.0
Content-Type: text/plain; charset=us-ascii
Content-Transfer-Encoding: 7bit
X-Virus-Checked: Checked by ClamAV on apache.org

Hi,

I am trying to send the same message to multiple endpoints in one
transaction. That means i what the transaction to rollback if any error is
encountered and one of the endpoints doesn't receive the message, resulting
in the fact that the message is sent to the deadLetterQueue and in the fact
that none of the endpoints actually receive the message.

I use validateMessageProcessor to simulate an exception.
My route is: 
   errorHandler(deadLetterChannel("activemq:dead"));
        onException(Exception.class)
                .maximumRedeliveries(0)
                .handled(true);
                
        from("activemq:jms/RoutingQueue")
                .transacted("PROPAGATION_REQUIRED")
                .to("activemq:jms/MihaiQueue")
                .to("activemq:jmsActive")
                                .process(validateMessageProcessor)
                .to("activemq:a");

The context is:
    <bean id="activemq"
class="org.apache.activemq.camel.component.ActiveMQComponent">
        <property name="transacted" value="true"/>
        <property name="transactionManager" ref="transactionManager"/>
    </bean>
    
    <bean id="transactionManager"
class="org.springframework.jms.connection.JmsTransactionManager">
        <property name="connectionFactory" ref="activeMQConnectionFactory"/>
    </bean>   
    
    <bean id="activeMQConnectionFactory"
class="org.apache.activemq.ActiveMQConnectionFactory">
        <property name="brokerURL" value="tcp://TEST:61616"/>
        <property name="redeliveryPolicy">
            <bean class="org.apache.activemq.RedeliveryPolicy">
                <property name="maximumRedeliveries" value="0"/>
            </bean>
        </property>
    </bean>  
    
    <bean id="PROPAGATION_REQUIRED"
class="org.apache.camel.spring.spi.SpringTransactionPolicy">
        <property name="transactionManager" ref="transactionManager"/>
        <property name="propagationBehaviorName"
value="PROPAGATION_REQUIRED"/>
    </bean>

My problem is the fact that the message still arrives in jms/MihaiQueue and
jmsActive, even though it arrives in deadLetterQueue too.
Since sending to "a" has failed i want the messages from jms/MihaiQueue and
jmsActive to be rolled back.

Do you have any suggestions as to what i am doing wrong?



--
View this message in context: http://camel.465427.n5.nabble.com/How-to-send-a-message-to-multiple-endpoints-in-one-transaction-tp5724749.html
Sent from the Camel Development mailing list archive at Nabble.com.