Spring集成和DSL升级-单向'MessageHandler'和配置'Output Channel'错误不合适

Question

public IntegrationFlow inBoundFlow(ConnectionFactory mqConnection)
    throws JMSException {

    return IntegrationFlows
            .from(Jms.messageDrivenChannelAdapter(mqConnection)
                    .configureListenerContainer(listenerContainer)
                    .destination(mqProperties.getQueue().getRequest())
                    .errorChannel(ErrorChannel())
                    .setHeaderMapper(new DefaultJmsHeaderMapper()))
            .filter(filterMessage, "filterMessage", m -> m.discardChannel(DiscardChannel()))
            .route(mqMessageRouter, "messageRouter")
            .handle(errorChannel, "handleError")
            .get();
}


@Named
public class MQErrorMessageChannel {

    @ServiceActivator(inputChannel = MQ_ERROR_MESSAGE_INPUT_CHANNEL, outputChannel = MQ_ERROR_MESSAGE_OUTPUT_CHANNEL)
    public Message<String> handleError(Throwable t) {
//Do Something....
        }
        return null;
    }
}

Answer 1

这种方法调用形式的.route(mqMessageRouter，“Messagerouter”）完全是单向的，您不能在流中指向之后的任何内容。

没有严格的决定哪个通道将是路由器之后的下一个，所以我们不能从那里继续流。

只需将您的流划分为几个流，并将.handle()添加到每个特定的路由流中。