温馨提示×

Spring Boot接收JMS消息的方法

小樊
81
2024-09-11 16:31:11
栏目: 编程语言

在Spring Boot中,接收JMS消息的方法主要是通过使用@JmsListener注解和配置JMS监听器容器。以下是一个简单的示例,展示了如何在Spring Boot应用程序中接收JMS消息:

  1. 首先,确保你已经在项目中添加了相关依赖。对于Maven项目,你需要在pom.xml文件中添加以下依赖:
   <groupId>org.springframework.boot</groupId>
   <artifactId>spring-boot-starter-activemq</artifactId>
</dependency>
  1. application.propertiesapplication.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
  1. 创建一个接收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方法将被调用,并打印出接收到的消息内容。

  1. 最后,确保你的Spring Boot应用程序已经启动并运行。现在,每当有新消息到达myQueue队列时,JmsMessageReceiver类中的receiveMessage方法将被调用。

0