Spring JMS topics durable subscriptions

[Ayelet <ay...@netomedia.com>]

Hi,

We're trying to set up ActiveMQ 5.9.0 as a message broker using JMS topics,
but we're having some issues with the consumption of the messages.

For testing purposes, we have a simple configuration of 1 topic, 1 event
producer, and 1 consumer. We send 10 messages one after the other, but every
time we run the application, 1-3 of these messages are not consumed! The
other messages are consumed and processed fine.
Apparently, the solution is to define durable topics, but we couldn't find a
comprehensive example of how to do that in the spring xmls.
This is our current configuration:

 <bean id="connectionFactory"
class="com.atomikos.jms.AtomikosConnectionFactoryBean"
    init-method="init" destroy-method="close">
    <property name="uniqueResourceName" value="amq" />
    <property name="xaConnectionFactory">
        <bean class="org.apache.activemq.spring.ActiveMQXAConnectionFactory"
            p:brokerURL="${activemq_url}" />
    </property>
    <property name="maxPoolSize" value="10" />
    <property name="localTransactionMode" value="false" />
</bean>

<bean id="cachedConnectionFactory"
    class="org.springframework.jms.connection.CachingConnectionFactory">
    <property name="targetConnectionFactory" ref="connectionFactory" />
</bean>


<bean id="jmsTemplate" class="org.springframework.jms.core.JmsTemplate">
    <property name="connectionFactory" ref="cachedConnectionFactory" />
    <property name="sessionTransacted" value="true" />
    <property name="pubSubDomain" value="true"/>
</bean>

<bean id="testTopic" class="org.apache.activemq.command.ActiveMQTopic">
    <constructor-arg value="test.topic" />
</bean>


<jms:listener-container destination-type="topic"
    connection-factory="connectionFactory"
transaction-manager="transactionManager"
    acknowledge="transacted" concurrency="1">
    <jms:listener destination="test.topic" ref="testReceiver"
        method="receive" />
</jms:listener-container>

Can anyone please help and provide an example/tutorial?
Thanks! :)





--
View this message in context: http://activemq.2283324.n4.nabble.com/Spring-JMS-topics-durable-subscriptions-tp4676235.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.