使用 Spring Boot 将消息发送到 JMS 队列



我是Spring JMS的新手。我的应用程序是使用 Spring Boot 开发的,部署在 JBoss EAP 7.2.0 中。我有一个远程队列,它是一个Active MQ Artemis队列,它也嵌入在JBoss EAP 7.2.0中。任何人都可以建议我如何使用Spring Boot的JmsTemplate向远程JMS队列发送消息吗?基本上我不明白我应该如何定义远程连接工厂以连接到远程队列。

  1. 在应用程序服务器中部署应用程序时,将以下内容添加到应用程序属性中
spring.jms.jndi-name=java:/<your connection factory name for artemis>
  1. 添加 artemis 依赖项并让 spring boot 自动配置 jmsTemplate
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-artemis</artifactId>
</dependency>
  1. 自动连接 jmsTemplate 并发送消息
@Component
public class MyMessageSender {
@Autowired
JmsTemplate jmsTemplate;

public void send(String msg){
jmsTemplate.convertAndSend("my.queue.name", msg);
}
}
  1. 您可以选择配置消息转换器并将pojos作为消息发送,并让spring负责将其转换为json。例如
@Bean // Serialize message content to json using TextMessage
public MessageConverter jacksonJmsMessageConverter() {
MappingJackson2MessageConverter converter = new MappingJackson2MessageConverter();
converter.setTargetType(MessageType.TEXT);
converter.setTypeIdPropertyName("_type");
return converter;
}

相关内容

  • 没有找到相关文章

最新更新