3

我正在使用一个带有一个目的地和一个消费者（消息侦听器）的消息侦听器容器：

<bean id="msgListenerContainer"

  class="org.springframework.jms.listener.DefaultMessageListenerContainer" 

  p:connectionFactory-ref="connectionFactory"

  p:destination-ref="destination"

  p:messageListener-ref="messageHandler"

  p:concurrentConsumers="10"

  p:maxConcurrentConsumers="50"

  p:receiveTimeout="5000"

  p:idleTaskExecutionLimit="10"

  p:idleConsumerLimit="5" />

如果我想要多个目的地，并且每个目的地都有一个消息侦听器，我应该怎么做？如果我想要一个目的地有多个听众，我该怎么办？

4

1 回答 1

3

1）您需要将spring应用程序上下文中的每个消息侦听器和生产者定义为bean。像这样的东西：

    <!-- MESSAGE LISTENER CONTAINER -->
<bean id="ListListenerContainer"
    class="org.springframework.jms.listener.DefaultMessageListenerContainer">
    <property name="messageListener" ref="messageListener" />
    <property name="connectionFactory" ref="qcf" />
    <property name="destinationResolver" ref="JmsDestinationResolver" />
    <property name="receiveTimeout" value="${jms-timeout}" />
    <property name="destinationName" value="${jms-list-topic}" />
    <property name="concurrency" value="1" />
    <property name="pubSubDomain" value="true" />
    <property name="subscriptionDurable" value="${jms-durable-flag}"/>
    <property name="durableSubscriptionName" value="${jms-list-durable-name}" />
    <property name="clientId" value="${jms-list-client-id}"/>
    <property name="sessionTransacted" value="true"/>
</bean> 


<bean id="publisher-1" class="com.stack.overflow.JmsPublisherImpl">
    <constructor-arg ref="jmsTemplate" />
</bean>

2）然后您可以使用自动装配或在将处理消息的类上的应用上下文（见下文）中定义的相关生产者。即上面的Message Listener bean ref指向的类：

<bean id="messageListener" class="com.stack.overflow.MessageHandler">
        <property name="publisher" ref="publisher-1" />
</bean>

这只是 1-2-1 映射。对于任何其他路由，您可以添加多个发布者（如上），然后由您决定如何实现所需的路由逻辑来决定哪个主题/队列应该发布从消费者 1 等收到的消息等

于 2012-10-10T15:42:35.520 回答