场景：群里有小伙伴求助jms activemq如何使用kettle 进行消费数据，之前连接过kafka，rabbtimq，想着activemq应该也没啥难度，结果低估了activemq。盘他！！！
插曲：ActiveMq 有两个版本：ActiveMQ Classic和ActiveMQ Artemis两个版本，kettle 中的jms插件连接activemq只支持ActiveMQ Artemis，结果我没有看官方文档一直用kettle 连接ActiveMQ Classic。。。
1、ActiveMQ Artemis服务安装（windows环境）
1）从官方地址（https://activemq.apache.org/）进行下载，注意选择合适的版本和本地jdk的版本。
2）解压文件 依次执行如下命令即可启动ActiveMQ服务
cd path/to/apache-artemis-<version>/bin
artemis create mybroker
cd mybroker/bin
bin/artemis run
3）测试JMS producer生产者（queue模式），如下图所示：
4、通过生成记录步骤产生一条数据，message为{"name":"java小金刚"}，如下图所示：
5、JMS producer设置，如下图所示：
Connection选择ActiveMQ
JMS URL设置为tcp://127.0.0.1:61616，通过tcp协议进行交互
Destination type：选择queue
Destination name：自定义设置，这里设置test
Message field：选择生成记录步骤中的输出字段message
6、保存&运行，数据正常写入activemq中间件，如下图所示：
7、测试JMS consumer消费者（queue模式），如下图所示：
8、JMS consumer设置（queue模式），如下图所示：
Transformation：设置子转换读取流数据，子转换使用到的步骤为Get records from stream
Connection选择ActiveMQ
JMS URL设置为tcp://127.0.0.1:61616，通过tcp协议进行交互
Destination type：选择queue
Destination name：和生产者保持一致，这里设置test
保存&运行，可以正常消费到数据
9、测试JMS producer生产者（topic模式），如下图所示：
Destination name：自定义设置，这里设置test.topic
10、保存&运行，数据可以正常写入activemq，如下图所示：
11、JMS consumer设置（topic模式），如下图所示：
Destination type：选择topic
Destination name：和生产者保持一致，这里设置test.topic
保存&运行，可以正常消费到数据
注意：在测试的时候先启动JMS consumer，然后使用JMS producer 推送数据。
12、activemq 使用amqp协议进行连接，调整url为amqp://127.0.0.1:5672，从错误信息来看kettle原生步骤不支持amqp协议，如下图所示：
标签：Destination,activemq,jms,kettle,JMS,所示,ActiveMQ,第八十九 From： https://www.cnblogs.com/zjBoy/p/18434062