//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
}这两种方法都需要函数方法。
1条答案
按热度按时间sd2nnvve1#
由于您正在从任意资源（本例中为jms）接收消息，并且希望使用s-c-stream将此类消息发送到rabbitmq，因此可以使用专门为此情况设计的组件-
StreamBridge只需自动连接它并在receive方法内部使用它向rabbit发送消息（前提是rabbit binder在类路径上）你不需要
你可以在这里找到更多信息