jsm transaction

[bmakhlin]

Hello,
I am using declarative mq jms transaction. I put message on the queue and throw an exception. I expect message to rollback but it does not rollback.

Why my message does not get rolled back. What am I missing?

<bean id="txManager" class="org.springframework.jms.connection.JmsTrans actionManager102">
<property name="connectionFactory">
<ref bean="jmsSingleQueueConnectionFactory" />
</property>
<property name="pubSubDomain">
<value>false</value>
</property>
</bean>
<tx:annotation-driven transaction-manager="txManager"/>

@Transactional(rollbackFor=Exception.class)
public void executeTransactionalMethod() throws Exception {
jmsTemplate.send(new MessageCreator() {
public Message createMessage(Session session) throws JMSException {
Message m = session.createTextMessage("Hello world1");
return m;
}
});
if (true) throw new Exception("error");
System.out.println("done ");
}

thanks

[Gary Russell]

Please use [ code]...[/code ] tags (no spaces) around code and config.

I was going to point out your <tx:annotation-driven/> element points to a different transaction manager, but I see you edited that.

How are you calling execute? For this to work, the class that contains the execute() method must be declared as a bean in the context, and invoked via the context either via injection, or getBean().

Spring transactions wrap the bean in a proxy; that's how the behavior is added; you can't call an @Transactional method directly from within the class (well, you can, but it won't get a transaction).

[bmakhlin]

Thanks your your help.

Here is a bean class I am using to test jms transaction and a bean declaration. Please, point out what am I missing. thanks

public class MQBackEnd2 {
	private JmsTemplate102 jmsTemplate;

	public JmsTemplate102 getJmsTemplate() {
		return jmsTemplate;
	}

	public void setJmsTemplate(JmsTemplate102 jmsTemplate) {
		this.jmsTemplate = jmsTemplate;
	}
	

	public void send(final String message, final String headerName, final String headerValue) {	    
	    jmsTemplate.send(new MessageCreator() {
            public Message createMessage(Session session) throws JMSException {
              Message m = session.createTextMessage(message);
              m.setStringProperty(headerName, headerValue);
              return m;
            }
        });		
	}
	
        @Transactional(rollbackFor=Exception.class)
        public void executeTransactionalMethod() throws Exception {
	    jmsTemplate.send(new MessageCreator() {
            public Message createMessage(Session session) throws JMSException {
              Message m = session.createTextMessage("Hello world1");
              return m;
            }
        });		
	    if (true) throw new Exception("error");
	    System.out.println("done ");
	}

	public static void main(String[] args) throws Exception {
		ClassPathResource res = new ClassPathResource("queueConfig.xml");
	    XmlBeanFactory factory = new XmlBeanFactory(res);  
	    final MQBackEnd2 mqBackEnd = MQBackEnd2)factory.getBean("mqBackEnd2");
	    
	    mqBackEnd.executeTransactionalMethod();
	    System.out.println("done ");

	}
}

<bean id="jmsQueueTemplate" class="org.springframework.jms.core.JmsTemplate102">
        <property name="connectionFactory">
            <ref bean="jmsSingleQueueConnectionFactory"/>
         </property>
         <property name="defaultDestination">
      	<ref bean="destination"/>
         </property>

        <property name="pubSubDomain">
            <value>false</value>
        </property>
        <property name="receiveTimeout">
            <value>20000</value>
        </property>
        <property name="sessionTransacted">
            <value>true</value>
        </property>
        
        <property name="sessionAcknowledgeMode">
	 <value>2</value>
        </property>
    </bean>
    

    <bean id="mqBackEnd2" class="com.thomson.ecom.core.client.queue.MQBackEnd2">
        <property name="jmsTemplate">
            <ref bean="jmsQueueTemplate"/>
         </property>
	
    </bean>

[Gary Russell]

Declarative @Transactions (and all Spring AOP behavior) only work with ApplicationContexts, not raw BeanFactories; you need

ApplicationContext ctx = new ClassPathXMLApplicationContext("queueConfig.xml");
...ctx.getBean(...