0

我是 Wso2 EI 和 MB 的新手。我在 jndi 属性文件中命名了一个“topic.salesOrderTopic=salesOrderTopic”。而且，我在 EI 中配置了一个消息存储，其参数如下：

<messageStore class="org.apache.synapse.message.store.impl.jms.JmsStore" name="salesOrderJmsStore" xmlns="http://ws.apache.org/ns/synapse">
    <parameter name="store.jms.destination">salesOrderJmsStore</parameter>
    <parameter name="store.producer.guaranteed.delivery.enable">false</parameter>
    <parameter name="store.jms.cache.connection">false</parameter>
    <parameter name="java.naming.factory.initial">org.wso2.andes.jndi.PropertiesFileInitialContextFactory</parameter>
    <parameter name="connectionfactory.QueueConnectionFactory">amqp://admin:admin@clientID/carbon?brokerlist='tcp://localhost:5675'</parameter>
    <parameter name="store.jms.JMSSpecVersion">1.1</parameter> </messageStore>

我还在我的机器中配置了两个消息处理器（部署了使用上述消息存储发布的相同代理）。我还可以在 MB 中看到两个消费者。奇怪的是只有一个处理器在处理发布的消息。另一个不是。如果我停用活动处理器，则另一个处理器正在处理消息而没有问题。你们能帮我理解我哪里出错了吗？我期待发布 - 订阅模型能够正常工作。

注意：在 MB 中，salesOrderTopic 列在队列列表和主题列表中。

4

0 回答 0