You are viewing a plain text version of this content. The canonical link for it is here.

Posted to users@activemq.apache.org by Ayelet <ay...@netomedia.com> on 2014/01/14 09:47:45 UTC

Spring JMS durable topics

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-durable-topics-tp4676266.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: Spring JMS durable topics

Posted by Ayelet <ay...@netomedia.com>.

Thanks, but even if we remove the caching, some messages still don't get
consumed.
We solved the problem using virtual topics.



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

Re: Spring JMS durable topics

Posted by Torsten Mielke <tm...@redhat.com>.

Hello,

Springs CachingConnectionFactory also caches consumers by default [1]. ActiveMQ prefetches messages to consumers and if there are multiple consumers in the cache of the CachingConnectionFactory you are not guaranteed to consume all messages.
Turn off consumer caching in the CachingConnectionFactory and re-test again. 
I would hope the problem is gone.


Regards,

Torsten Mielke
tmielke.blogspot.com

[1] http://docs.spring.io/spring/docs/3.0.5.RELEASE/api/org/springframework/jms/connection/CachingConnectionFactory.html#isCacheConsumers()


On 14 Jan 2014, at 09:47 am, Ayelet <ay...@netomedia.com> wrote:

> 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-durable-topics-tp4676266.html
> Sent from the ActiveMQ - User mailing list archive at Nabble.com.