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!