Problema con la configuracion de JMS en spring.

[Rapidiablo]

No se si este es el mejor lugar para postear esta consulta pero bueno, el asunto es asi, tengo el siguiente archivo de configuraciones en spring:

Código:

    <bean id="connectionFactory" class="org.apache.activemq.ActiveMQConnectionFactory">
        <property name="brokerURL">
            <value>tcp://localhost:61616</value>
        </property>
    </bean>
 
    <bean id="destination" class="org.apache.activemq.command.ActiveMQTopic">
        <constructor-arg value="testTopic"/>
    </bean>
 
    <bean id="jmsTemplate" class="org.springframework.jms.core.JmsTemplate">
        <property name="connectionFactory" ref="connectionFactory"/>
        <property name="defaultDestination" ref="destination"/>
    </bean>
    
    <bean id="orderSender" class="com.testapp.test.security.client.test.MessageSender" />

    <jms:listener-container connection-factory="connectionFactory">
        <jms:listener destination="testTopic" ref="messageReceiver" method="receive"/>
    </jms:listener-container>

</beans>

Esas configuraciones funcionan bien para publicar y escuchar en un queue. El tema es que yo quiero mandar mansajes a un topic y principalmente escuchar ese topic.

Como veran en el codigo, ya hice los cambios para cambiar el destino y enviar todo a un topic enves de un queue:

<bean id="destination" class="org.apache.activemq.command.ActiveMQTopic"

Antes tenia:

<bean id="destination" class="org.apache.activemq.command.ActiveMQQueue">

lo extraño es que ambas configuraciones dan el mismo resultado?. Alguien sabe que estoy haciendo mal?

Saludos y Gracias por pasar!

[Rapidiablo]

Nadie sabe que estoy haciendo mal?

[Rapidiablo]

Bueno para no dejar este tema colgago. La solucion fue esta:

Código:

    <jms:listener-container container-type="default" 
    						connection-factory="connectionFactory"
    						acknowledge="auto"
    						destination-type="topic">
        <jms:listener destination="logTopic" ref="messageReceiver" method="receive"/>
    </jms:listener-container>

Saludos.