我已经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>
我究竟做错了什么?