spring-boot - 带 Spring Boot 的 Tibco jms

Question

我正在使用 tibco ems 项目开发 spring boot。

需要创建生产者和消费者配置。任何人都可以指导配置

Answer 1

导入tibjms.jar库，然后:

import com.tibco.tibjms.TibjmsConnectionFactory;

并创建以下 beans:

  @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");