在Spring Boot中,接收JMS消息的方法主要是通過使用@JmsListener
注解和配置JMS監聽器容器。以下是一個簡單的示例,展示了如何在Spring Boot應用程序中接收JMS消息:
pom.xml
文件中添加以下依賴: <groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-activemq</artifactId>
</dependency>
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
@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
方法將被調用,并打印出接收到的消息內容。
myQueue
隊列時,JmsMessageReceiver
類中的receiveMessage
方法將被調用。