从 IBM MQ spring 引导侦听器接收有效负载，然后以功能方法将数据发送到 rabbitmq

Question

//take message from ibm mq    
@JmsListener(destination = "${ibm.mq.ackqueue}", concurrency="${ibm.mq.concurrency}")
public void receive(Message message){//get playload}

@Bean
public Function<Response, EventDto> transformEvent() {
//take response from ibm mq
//then process and send eventdto to rabbit mq from spring cloud stream approach
}

这两个方法都是需要函数式的方法。

Answer 1

由于您正在从任意资源（在本例中为 JMS）接收消息，并且您希望使用 s-c-stream 将此类消息发送到 RabbitMQ，因此您可以使用专为这种情况设计的组件 - StreamBridge

简单地自动装配它并在 receive 方法中使用它来向 Rabbit 发送消息（假设 rabbit binder 在类路径上）

你不需要

@Bean
public Function<Response, EventDto> transformEvent() {
//take response from ibm mq
//then process and send eventdto to rabbit mq from spring cloud stream approach
}

您可以找到更多信息here

从 IBM MQ spring 引导侦听器接收有效负载，然后以功能方法将数据发送到 rabbitmq

Receive Payload from IBM MQ spring boot listner then send data to rabbit mq in functional approch

spring

spring-cloud

spring-cloud-stream