下面是一个直截了当的 spring 支持的 activemq 配置,我没有太多麻烦,因为我遵循了文档。基本上有一个生产者使用jmsTemplate向其发送消息的队列,配置如下,经过测试,我没有问题:
<bean id="jmsFactory" class="org.apache.activemq.pool.PooledConnectionFactory"
destroy-method="stop">
<property name="connectionFactory">
<bean class="org.apache.activemq.ActiveMQConnectionFactory">
<property name="brokerURL"
value="${activemq.brokerUrl}" />
<property name="sendTimeout"
value="${activemq.sendTimeout}" />
<property name="prefetchPolicy">
<bean class="org.apache.activemq.ActiveMQPrefetchPolicy">
<property name="queuePrefetch" value="0" />
</bean>
</property>
</bean>
</property>
</bean>
<amq:queue id="classifiedEventSink"
physicalName="${activemq.classifiedEventSink.producer}" />
<bean id="jmsTemplateClassifiedEventSink"
class="org.springframework.jms.core.JmsTemplate">
<property name="connectionFactory" ref="jmsFactory" />
<property name="defaultDestination" ref="classifiedEventSink" />
<property name="sessionAcknowledgeModeName" value="AUTO_ACKNOWLEDGE" />
</bean>
现在保持这个配置,我想让它成为一个镜像队列,每次生产者向队列添加消息时,我希望该消息在主题上广播。诀窍是在 spring 上进行配置,因为我很难找到示例。你能指出我的任何方向吗?