2016-05-19 40 views
3

我已经有了Message Broker 3.1.0,我试图通过java程序发布消息,并通过JMeter脚本订阅,我在Windows中以无头模式运行它。处理多个主题,发布者和订阅者的错误+ WSO2MB

所以在我的情况下,我已经在MB中添加了三个主题,通过cmd执行三个不同的java类,以便发布消息以及通过JMeter GUI创建的三个不同的订阅者。我在此提供url用于通过JMeter GUI生成的jmx文件之一。据我所知,下列属性在所有三个JMX文件被更改:

  • 名= “jms.provider_url
  • NAME =” jms.topic”

我创建了3个不同的jndi.property文件每一个都具有以下属性的订户:

  • connectionfactory.TopicConnectionFactory = AMQP://管理员:?管理员@ clientID的/碳brokerlist ='TCP:/ /本地主机:5672'
  • topic.Games =游戏(我只改变了这对其他两个主题为 好,即:主题名称)

一旦我开始发布和订阅所有三个,我m遇到以下错误。

INFO {org.wso2.andes.server.protocol.AMQProtocolEngine} - 关闭通道由于:org.wso2.andes.AMQInternalException:独家绑定已经存在不同的主题。不允许。 [错误代码541:内部错误] INFO {org.wso2.andes.server.exchange.TopicExchange} - 消息路由键:游戏没有路由。 [2016-05-19 16:38:13,953] INFO {org.wso2.andes.kernel.disruptor.inbound.MessagePreProcessor} - 消息路由键:游戏集群中没有路由。忽略消息ID

我可以理解,jmx文件的某些属性/属性已被复制或在所有三个文件中引用同一个事物。我哪里可能出错了?任何帮助,将不胜感激。

回答

2

我通过在所有三个jmx文件中将jms.durableSubscriptionIdjms.clientId更改为不同的ID来解决这个问题。

相关问题