【发布时间】:2020-05-22 00:08:35
【问题描述】:
我正在使用 tibco ems 项目开发 Spring Boot。
需要创建生产者和消费者配置。任何人都可以指导配置
【问题讨论】:
标签: spring-boot tibco ems
我正在使用 tibco ems 项目开发 Spring Boot。
需要创建生产者和消费者配置。任何人都可以指导配置
【问题讨论】:
标签: spring-boot tibco ems
导入 tibjms.jar 库,然后:
import com.tibco.tibjms.TibjmsConnectionFactory;
并创建以下 bean:
@Bean
public TibjmsConnectionFactory connectionFactory() {
TibjmsConnectionFactory connectionFactory = new TibjmsConnectionFactory("tcp://localhost:7222");
return connectionFactory;
}
@Bean
public JmsTemplate JmsTemplate() {
JmsTemplate jmsTemplate =
new JmsTemplate(connectionFactory());
return jmsTemplate;
}
接收者将是:
@Component
public class Receiver {
@JmsListener(destination = "test_queue")
public void receiveMessage(String message) {
System.out.println("Received <" + message + ">");
}
}
发件人将是:
JmsTemplate jmsTemplate = context.getBean(JmsTemplate.class);
jmsTemplate.convertAndSend("test_queue", "Hello");
【讨论】: