java - 如何使用 ActiveMQ 消费来自虚拟主题的消息？

Question

我正在向名为 VirtualTopic.Orders 的虚拟主题发布消息(通过 spring-jms)。我将消息发布到 ActiveMQ 没有任何问题，并且可以在 VirtualTopic.Orders 队列中看到该消息，但我无法使用它。这是我的 JmsTemplate bean 声明:

<bean id="jmsTemplateBusinessEvents" class="org.springframework.jms.core.JmsTemplate">
    <property name="connectionFactory" ref="jmsConnectionFactory"/>
    <property name="pubSubDomain" value="true"/>
</bean>

我已将 pubSubDomain 设置为 true，因为 this explanation 。

我还按照说明更改了配置文件 activemq.xml here :

<destinationInterceptors>
    <virtualDestinationInterceptor>
        <virtualDestinations>
            <virtualTopic name="VirtualTopic.>" prefix="Consumer.*.VirtualTopic.>" selectorAware="false"/>
        </virtualDestinations>
     </virtualDestinationInterceptor>
</destinationInterceptors>

这是我的消费者指向 Consumer.A.VirtualTopic.Orders 队列:

<bean class="org.springframework.jms.listener.DefaultMessageListenerContainer" init-method="start"
          lazy-init="false">
    <property name="connectionFactory" ref="jmsConnectionFactory"/>
    <property name="destinationName" value="Consumer.A.VirtualTopic.Orders"/>
    <property name="messageListener" ref="processStatusHandler"/>
</bean>

如果有人能帮助我，我将不胜感激。

Answer 1

我已经遇到这个问题了。消费者前缀值不正确必须是:

<destinationInterceptors>
    <virtualDestinationInterceptor>
        <virtualDestinations>
            <virtualTopic name="VirtualTopic.>" prefix="Consumer.*.>" selectorAware="false"/>
        </virtualDestinations>
     </virtualDestinationInterceptor>
</destinationInterceptors>