时间戳

首页 > 解决方案 > WSO2 IoT Server 中的 ActiveMQ 连接被拒绝问题

wso2 - WSO2 IoT Server 中的 ActiveMQ 连接被拒绝问题

问题描述

我已经jar在 IoT 服务器中包含了所需的文件，并且 IoT Broker 控制台显示 JMS 提供程序已启动并正在运行，如下所示

[2018-06-06 23:21:09,764] [IoT-Broker]  INFO {org.wso2.carbon.identity.user.store.configuration.deployer.UserStoreConfigurationDeployer} -  User Store Configuration Deployer initiated.
[2018-06-06 23:21:09,765] [IoT-Broker]  INFO {org.wso2.carbon.identity.user.store.configuration.deployer.UserStoreConfigurationDeployer} -  User Store Configuration Deployer initiated.
[2018-06-06 23:21:10,659] [IoT-Broker]  INFO {org.apache.axis2.transport.jms.JMSConnectionFactory} -  JMS ConnectionFactory : myTopicConnectionFactory initialized
[2018-06-06 23:21:10,660] [IoT-Broker]  INFO {org.apache.axis2.transport.jms.JMSConnectionFactory} -  JMS ConnectionFactory : default initialized
[2018-06-06 23:21:10,661] [IoT-Broker]  INFO {org.apache.axis2.transport.jms.JMSConnectionFactory} -  JMS ConnectionFactory : myQueueConnectionFactory initialized
[2018-06-06 23:21:10,661] [IoT-Broker]  INFO {org.apache.axis2.transport.jms.JMSListener} -  JMS Transport Receiver/Listener initialized...
[2018-06-06 23:21:10,724] [IoT-Broker]  INFO {org.apache.axis2.deployment.ModuleDeployer} -  Deploying module: addressing-1.6.1-wso2v22 - file:/Users/amar/Documents/ThesisCode/CEP_codes/wso2iot_server/wso2/broker/repository/deployment/client/modules/addressing-1.6.1-wso2v22.mar
[2018-06-06 23:21:10,739] [IoT-Broker]  INFO {org.apache.axis2.transport.jms.JMSSender} -  JMS Sender started
[2018-06-06 23:21:10,739] [IoT-Broker]  INFO {org.apache.axis2.transport.jms.JMSSender} -  JMS Transport Sender initialized...
[2018-06-06 23:21:11,058] [IoT-Broker]  INFO {org.apache.axis2.deployment.DeploymentEngine} -  Deploying Web service: org.wso2.carbon.andes.admin-3.2.16 -

但是，我在IoT Analytics控制台中收到以下错误。

Caused by: javax.jms.JMSException: Could not connect to broker URL: tcp://localhost:61616. Reason: java.net.ConnectException: Connection refused (Connection refused)

JMS 发布者适配器的代码是

<?xml version="1.0" encoding="UTF-8"?>
<eventPublisher name="scep_s1_jmss" processing="enable"
  statistics="enable" trace="enable" xmlns="http://wso2.org/carbon/eventpublisher">
  <from streamName="stream1_scep_timestamped" version="1.0.0"/>
  <mapping customMapping="disable" type="text"/>
  <to eventAdapterType="jms">
    <property name="transport.jms.DestinationType">queue</property>
    <property name="transport.jms.Destination">queue1</property>
    <property name="transport.jms.ConcurrentPublishers">allow</property>
    <property name="java.naming.factory.initial">org.apache.activemq.jndi.ActiveMQInitialContextFactory</property>
    <property name="java.naming.provider.url">tcp://localhost:61616</property>
    <property name="transport.jms.ConnectionFactoryJNDIName">QueueConnectionFactory</property>
    <property name="transport.jms.UserName">admin</property>
    <property encrypted="true" name="transport.jms.Password">aa47+5/q7d9AvOHUyYAJDXrx0Q6GQmgzIKS/hOkzp6huHrxslJJk6Oqmv2mrW159DOTfJ7Rw2nBbfGWjGiMckTFAO9p9YVF3kDDHhiyirWEJPSESSSJeBB782qnwoXEDSAjgiiUYWSRuYIfxdibXUUZr3JPSmjaxvy+EVMjjWgouMrid51UQTW50wl3C0fX03/nak4P9+GWx14T1JGAb07fKQlgK/AwYtJ8esNyiV1j0Z2jgGM9OLpqgZ9gqjsA95htzdqy2DgC/U74qfhkUKISAXUWZdGS+rCEYBFaVzAj0aPKtXmRWTrC6OTDSTVLQCKZPfcHqnU652PUQZqqKCA==</property>
  </to>
</eventPublisher>

我究竟做错了什么？

标签： wso2wso2esbwso2carbonwso2iot

解决方案

我已经单独安装了 ActiveMQ 并在终端控制台中启动它。然后启动 wso2 IoT 服务器。这解决了我的问题

推荐阅读