Can anybody help? It's been more than three weeks... What I have seems to be the simplest possible transacted coniguration of ActiveMQ + Spring where I recieve and send messages in transaction. I can't believe people don't have a problem similar to mine...
kpetrov wrote: > > I'm trying to setup a simple transactional setup where I receive a message > using "DefaultMessageListenerContainer" and then send it using > JmsTemplate. > When I look at the log I have the following messages non stop: > > 13:14:54 DEBUG ID:kvp-pro-2.local-61811-1212437692103-2:0:5 Transaction > Commit > 13:14:54 DEBUG ID:kvp-pro-2.local-61811-1212437692103-2:0:12 Transaction > Commit > 13:14:54 DEBUG Removing consumer: > ID:kvp-pro-2.local-61811-1212437692103-2:0:5:1 > 13:14:54 DEBUG ID:kvp-pro-2.local-61811-1212437692103-2:0:15 Transaction > Commit > 13:14:54 DEBUG ID:kvp-pro-2.local-61811-1212437692103-2:0:8 Transaction > Commit > 13:14:54 DEBUG Removing consumer: > ID:kvp-pro-2.local-61811-1212437692103-2:0:12:1 > 13:14:54 DEBUG ID:kvp-pro-2.local-61811-1212437692103-2:0:10 Transaction > Commit > 13:14:54 DEBUG Adding consumer: > ID:kvp-pro-2.local-61811-1212437692103-2:0:16:1 > 13:14:54 DEBUG Removing consumer: > ID:kvp-pro-2.local-61811-1212437692103-2:0:15:1 > 13:14:54 DEBUG Adding consumer: > ID:kvp-pro-2.local-61811-1212437692103-2:0:17:1 > 13:14:54 DEBUG Adding consumer: > ID:kvp-pro-2.local-61811-1212437692103-2:0:18:1 > > I looked up the thread that essentially suggested that starting from > spring 2.5.1 I should not have this problem. I'm using 2.5.4. I have an > embedded active mq broker 5.1. There are no messages in the queue. Does > anybody know what is going on? > > Below is the my spring configuration: > > <bean id="connectionFactory" > class="org.apache.activemq.ActiveMQConnectionFactory" > depends-on="activemqWrapper"> > <property name="brokerURL" > value="${brokerTransport}://${brokerHost}:${brokerPort}" /> > </bean> > > <bean id="singleConnectionFactory" > > class="org.springframework.jms.connection.SingleConnectionFactory" > destroy-method="destroy"> > <property name="targetConnectionFactory" > ref="connectionFactory"/> > </bean> > > > <bean id="jmsTemplate" > class="org.springframework.jms.core.JmsTemplate"> > <property name="connectionFactory" > ref="singleConnectionFactory" /> > <property name="explicitQosEnabled" value="true" /> > <property name="sessionTransacted" value="true" /> > </bean> > > <bean id="jmsTransactionManager" > class="org.springframework.jms.connection.JmsTransactionManager" > > <property name="connectionFactory" > ref="singleConnectionFactory"/> > </bean> > > > <bean > > class="org.springframework.jms.listener.DefaultMessageListenerContainer"> > <property name="connectionFactory" > ref="singleConnectionFactory" /> > <property name="destination" ref="central.incomingQueue" /> > <property name="messageListener" ref="incomingMdp" /> > <!-- --> > <property name="transactionManager" ref="jmsTransactionManager" > /> > > <property name="sessionTransacted" value="true"/> > <property name="concurrentConsumers" value="5" /> > </bean> > > -- View this message in context: http://www.nabble.com/spring-transaction-configuration%2C-AMQ-5.1-tp17610003p18205322.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.