Example of using Local Transaction

[vveludan]

Good evening.
Following is the rabbit broker, message listener container, message listener adapter and handler configuration:

<context:component-scan base-package="com.test.log"/>

<contextroperty-placeholder location="file:///var/test/amqp.properties"/>

<!-- messaging config -->
<bean id="messageListenerContainer" class="org.springframework.amqp.rabbit.listener.Si mpleMessageListenerContainer">
<property name="connectionFactory" ref="connectionFactory"/>
<property name="queueName" value="loqQueue"/>
<property name="concurrentConsumers="1"/>
<property name="messageListener" ref="messageListenerAdapter"/>
</bean>

<bean id="messageListenerAdapter" class="org.springframework.listener.adapter.Messag eListenerAdapter">
<property name="delegate" ref="logHandler"/>
<property name="messageConverter" ref="messageConverter"/>
</bean>

<bean id="logHandler" class="com.test.log.LoggingHandler"/>


In my LoggingHandler.handleMessage() method, for some reason I have to rollBack a message, in other words I would like put it back on queue and process it again. Could you please let me know how I would do it.

Thanks
Venkat

[ndpar]

I think local transaction management is not implemented yet: https://jira.springsource.org/browse/AMQP-49