我正在使用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");