springboot 集成 activemq 消费者

要在Spring Boot中集成ActiveMQ消费者，你需要执行以下步骤：

1. 添加Maven依赖：在你的`pom.xml`文件中添加以下依赖：

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-activemq</artifactId>
</dependency>

2. 配置ActiveMQ连接：在`application.properties`文件中添加以下配置：

spring.activemq.broker-url=tcp://localhost:61616
spring.activemq.user=admin
spring.activemq.password=admin

3. 创建消息监听器：创建一个类来实现`MessageListener`接口，用于处理接收到的消息。例如：

import javax.jms.Message;
import javax.jms.MessageListener;

public class MyMessageListener implements MessageListener {
    @Override
    public void onMessage(Message message) {
        // 处理接收到的消息
    }
}

4. 注册消费者：在你的Spring Boot应用程序中，使用`@JmsListener`注解注册消息监听器。例如：

import org.springframework.jms.annotation.JmsListener;
import org.springframework.stereotype.Component;

@Component
public class MyMessageConsumer {
    @JmsListener(destination = "myQueue")
    public void receiveMessage(String message) {
        System.out.println("Received message: " + message);
    }
}

在上面的例子中，我们使用`@JmsListener`注解来指定要监听的目标队列名字为`myQueue`，并在`receiveMessage()`方法中处理接收到的消息。

现在，当有消息到达`myQueue`队列时，`receiveMessage()`方法将被调用，并打印接收到的消息。

这就是在Spring Boot中集成ActiveMQ消费者的基本步骤。你可以根据自己的需求进行进一步的配置和处理。