//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
}这两种方法都是需要函数的方法。
发布于 2021-02-21 00:32:26
由于您从任意资源(本例中为JMS)接收消息,且希望使用s-c- RabbitMQ发送此类消息,因此可以使用专门针对这种情况设计组件- StreamBridge
只需自动连接它,并在接收方法中使用它来向Rabbit发送消息(假设rabbit绑定器在类路径上)
你不需要
@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上找到更多信息
https://stackoverflow.com/questions/66288908
复制相似问题