如何在 WSO2ESB 和 WSO2 MB 中设置端口

How to set port in WSO2ESB and WSO2 MB

正在使用 WSO2 ESB 4.7.0 和 WSO2 MB 2.2.0。

我已经按照以下 link:

在 WSO2 ESB 和 WSO2 MB 之间进行了集成

https://docs.wso2.com/display/MB220/Integrating+WSO2+ESB

我已经使用如下所示的端口成功启动了 MB 服务器

[2015-01-19 14:32:20,868]  INFO {org.wso2.andes.server.cluster.GlobalQueueManager} -  Starting Global Queue Worker for Global Queue : GlobalQueue_9
[Broker] BRK-1002 : Starting : Listening on TCP port 5675
[2015-01-19 14:32:26,132]  INFO {qpid.message.broker.listening} - [Broker] BRK-1002 : Starting : Listening on TCP port 5675
[Broker] BRK-1002 : Starting : Listening on TCP/SSL port 8675
[2015-01-19 14:32:26,138]  INFO {qpid.message.broker.listening} -  [Broker] BRK-1002 : Starting : Listening on TCP/SSL port 8675
[Broker] BRK-1004 : Qpid Broker Ready

当我启动 ESB 服务器时,它显示如下所示的错误

[2015-01-19 14:37:34,275]  INFO - AMQConnection Unable to connect to  broker at tcp://localhost:5672
 org.wso2.andes.transport.TransportException: Could not open connection
at org.wso2.andes.transport.network.mina.MinaNetworkTransport$IoConnectorCreator.connect(MinaNetworkTransport.java:216)
at org.wso2.andes.transport.network.mina.MinaNetworkTransport.connect(MinaNetworkTransport.java:74)
at org.wso2.andes.client.AMQConnectionDelegate_8_0.makeBrokerConnection(AMQConnectionDelegate_8_0.java:120)
at org.wso2.andes.client.AMQConnection.makeBrokerConnection(AMQConnection.java:616)
at org.wso2.andes.client.AMQConnection.<init>(AMQConnection.java:398)

我不确定,但我认为 esb 尝试连接到代理的端口不匹配,有什么方法可以更改此端口以成功连接到代理..?

帮我解决这个问题。

因为你有 3 作为端口偏移量,请执行以下操作

打开 <ESB_HOME>/repository/conf/JNDI.proerties 文件并指向 运行 Message Broker。

使用 carbon 作为虚拟主机。定义一个名为 JMSMS 的队列。注释掉该主题,因为它不需要。但是,为了避免在服务器启动期间获得 javax.naming.NameNotFoundException: TopicConnectionFactory,还要将 TopicConnectionFactory 指向 Message Broker。

# register some connection factories
# connectionfactory.[jndiname] = [ConnectionURL]
connectionfactory.QueueConnectionFactory = amqp://admin:admin@clientID/carbon?brokerlist='tcp://localhost:5675'
connectionfactory.TopicConnectionFactory = amqp://admin:admin@clientID/carbon?brokerlist='tcp://localhost:5675'
# register some queues in JNDI using the form
# queue.[jndiName] = [physicalName]
queue.JMSMS=JMSMS
queue.StockQuotesQueue = StockQuotesQueue