WSO2 ESB AMQ 连接错误
WSO2 ESB AMQ Connection Error
我正在使用 WSO2 ESB 4.7.0 和 WSO2 MB 2.2.0。
我想使用 JMS 队列发布和订阅消息的概念。为此,我按照以下 link:
在 WSO2 ESB 和 WSO2 MB 之间进行了集成
https://docs.wso2.com/display/MB220/Integrating+WSO2+ESB
我已按照文档中提到的所有步骤尝试重新启动 ESB 服务器,但未能启动服务器,原因如下:
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)
at org.wso2.andes.client.AMQConnectionFactory.createConnection(AMQConnectionFactory.java:328)
at org.wso2.andes.client.AMQConnectionFactory.createConnection(AMQConnectionFactory.java:38)
at org.wso2.carbon.message.store.persistence.jms.util.JMSUtil.createConnection(JMSUtil.java:46)
at org.wso2.carbon.message.store.persistence.jms.JMSMessageStore.createConnection(JMSMessageStore.java:717)
at org.wso2.carbon.message.store.persistence.jms.JMSMessageStore.getReadConnection(JMSMessageStore.java:634)
at org.wso2.carbon.message.store.persistence.jms.JMSMessageStore.newConsumer0(JMSMessageStore.java:1040)
at org.wso2.carbon.message.store.persistence.jms.JMSMessageStore.fetchInto(JMSMessageStore.java:284)
at org.wso2.carbon.message.store.persistence.jms.SamplingHandler.execute(SamplingHandler.java:67)
at org.quartz.core.JobRunShell.run(JobRunShell.java:213)
at org.quartz.simpl.SimpleThreadPool$WorkerThread.run(SimpleThreadPool.java:557)
如何克服这个错误并成功启动ESB服务器?
需要对 ESB 中存在的任何文件进行进一步配置。
这可能是端口配置问题。
教程提到在JDNI.properties文件中将两个连接工厂的端口设置为5673 ESB 在为 Message Broker 应用端口偏移后,但在尝试连接到 Message Broker 时在端口 5672 上出现异常。确保两者匹配。
如果将端口偏移设置为 1,您应该在 Message Broker 日志中看到类似这样的内容:
INFO {qpid.message.broker.listening} - [Broker] BRK-1002 : Starting : Listening on TCP port 5673
我正在使用 WSO2 ESB 4.7.0 和 WSO2 MB 2.2.0。
我想使用 JMS 队列发布和订阅消息的概念。为此,我按照以下 link:
在 WSO2 ESB 和 WSO2 MB 之间进行了集成https://docs.wso2.com/display/MB220/Integrating+WSO2+ESB
我已按照文档中提到的所有步骤尝试重新启动 ESB 服务器,但未能启动服务器,原因如下:
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)
at org.wso2.andes.client.AMQConnectionFactory.createConnection(AMQConnectionFactory.java:328)
at org.wso2.andes.client.AMQConnectionFactory.createConnection(AMQConnectionFactory.java:38)
at org.wso2.carbon.message.store.persistence.jms.util.JMSUtil.createConnection(JMSUtil.java:46)
at org.wso2.carbon.message.store.persistence.jms.JMSMessageStore.createConnection(JMSMessageStore.java:717)
at org.wso2.carbon.message.store.persistence.jms.JMSMessageStore.getReadConnection(JMSMessageStore.java:634)
at org.wso2.carbon.message.store.persistence.jms.JMSMessageStore.newConsumer0(JMSMessageStore.java:1040)
at org.wso2.carbon.message.store.persistence.jms.JMSMessageStore.fetchInto(JMSMessageStore.java:284)
at org.wso2.carbon.message.store.persistence.jms.SamplingHandler.execute(SamplingHandler.java:67)
at org.quartz.core.JobRunShell.run(JobRunShell.java:213)
at org.quartz.simpl.SimpleThreadPool$WorkerThread.run(SimpleThreadPool.java:557)
如何克服这个错误并成功启动ESB服务器?
需要对 ESB 中存在的任何文件进行进一步配置。
这可能是端口配置问题。
教程提到在JDNI.properties文件中将两个连接工厂的端口设置为5673 ESB 在为 Message Broker 应用端口偏移后,但在尝试连接到 Message Broker 时在端口 5672 上出现异常。确保两者匹配。
如果将端口偏移设置为 1,您应该在 Message Broker 日志中看到类似这样的内容:
INFO {qpid.message.broker.listening} - [Broker] BRK-1002 : Starting : Listening on TCP port 5673