Announcement Announcement Module
Collapse
No announcement yet.
Example of using Local Transaction Page Title Module
Move Remove Collapse
X
Conversation Detail Module
Collapse
  • Filter
  • Time
  • Show
Clear All
new posts

  • Example of using Local Transaction

    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

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

    Comment

    Working...
    X