0

下面是一个直截了当的 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 上进行配置,因为我很难找到示例。你能指出我的任何方向吗?

4

1 回答 1

0

您可以在 ActiveMQ 代理配置中执行此操作,如下所示:http: //activemq.apache.org/mirrored-queues.html

于 2013-01-23T03:23:49.680 回答