在本章中，我们将学习ActiveMQ与Camel一起工作的基础知识。

配置为ActiveMQ组件

在我们的代码中使用ActiveMQ队列或主题之前，我们必须配置ActiveMQComponent。可以按以下程序所示对ActiveMQComponent进行最小配置-

• brokerURL-指定AMQ Broker的主机和端口。
• 用户名-指定用于连接到AMQ Broker的用户名。
• 密码-指定用于连接到AMQ Broker的密码。

连接到队列

现在我们已经配置了ActiveMQComponent，我们可以在CamelContext中将其用作端点。

我们将使用以下格式的AMQ端点-

Activemq:[queue|topic]:[queueName|topicName]

将消息写到AMQ

在Fuse容器中部署此捆绑包之后，您应该能够看到发布到AMQ的消息，这些消息作为文件放置在D：/ src / data中。

输入项

D：/src/data/input.txt

Test me

输出

从AMQ读取

输入项

部署此捆绑包之后，您应该看到D：/ src中正在生成一个文件，并且消息已被使用。还应为该队列显示消费者。

输出

D：/源

Test me

写作主题

从主题阅读

输入项

D：/src/file1.xml

   
      value1
   



   
      value2
   



   
      value3
   

输出

D：/ src /

   
      value1
   



   
      value2
   



   
      value3