在Spring Boot中,接收JMS消息的方法主要是通过使用@JmsListener
注解和配置JMS监听器容器。以下是一个简单的示例,展示了如何在Spring Boot应用程序中接收JMS消息:
- 首先,确保你已经在项目中添加了相关依赖。对于Maven项目,你需要在
pom.xml
文件中添加以下依赖:
org.springframework.boot spring-boot-starter-activemq
- 在
application.properties
或application.yml
文件中配置ActiveMQ连接信息:
# ActiveMQ connection info spring.activemq.broker-url=tcp://localhost:61616 spring.activemq.user=admin spring.activemq.password=admin spring.activemq.packages.trust-all=true
- 创建一个接收JMS消息的服务类,并使用
@JmsListener
注解指定要监听的队列或主题:
import org.springframework.jms.annotation.JmsListener; import org.springframework.stereotype.Service; @Service public class JmsMessageReceiver { @JmsListener(destination = "myQueue") public void receiveMessage(String message) { System.out.println("Received message: " + message); } }
在这个例子中,我们创建了一个名为JmsMessageReceiver
的服务类,并使用@JmsListener
注解指定了要监听的队列(myQueue
)。当有新消息到达队列时,receiveMessage
方法将被调用,并打印出接收到的消息内容。
- 最后,确保你的Spring Boot应用程序已经启动并运行。现在,每当有新消息到达
myQueue
队列时,JmsMessageReceiver
类中的receiveMessage
方法将被调用。