Spring集成DSL：lambda在句柄方法中返回Message，例如使用委托SessionFactory？

Question

动机：我需要在路由到Sftp出站网关之前设置委托SessionFactory的threadKey，然后取消设置threadKey。

根据租户的不同，我需要使用不同的Sftp用户帐户。在我的应用程序中，用户帐户是一个配置问题。yml，我不想为每个新租户写单独的路由。

public IntegrationFlow aDynamicSftpFlow() {
    f -> f
        .handle(tenantSessionDefine()) // how can I use a lambda instead?
        .handle(Sftp.outboundGateway(delegatingSessionFactory, ...))
        .handle(...) // undefine sftp session
}

设置threadKey需要消息

public class TenantSessionDefine {


    private DelegatingSessionFactory delegatingSessionFactory;

    public TenantSessionDefine(DelegatingSessionFactory delegatingSessionFactory) {
        this.delegatingSessionFactory = delegatingSessionFactory;
    }

    public Message<?> defineSession(Message<?> message) {
        return delegatingSessionFactory.setThreadKey(message, message.getHeaders()
            .get("tenantId", String.class)); 
// used by SessionFactoryLocator
    }
}

我想把它写成lambda，比如

.handle(message -> delegatingSessionFactory.setThreadKey(message, 
    message.getPayload().getTenant())

但这并不容易。可以与接受消息的句柄（）一起使用的lambda

这只是一个示例，我希望我可以在lambda中使用带有消息的handle（），而不结束流。我该怎么做？

使现代化

DelegatingSessionFactory不是一个特别合适的例子。由于设置和清除线程键应该在sftp调用之前和之后进行，因此通知比在调用之前和之后定义处理程序更合适。




Answer 1

知道了。handle（）的javadoc表示

如果您需要访问整个消息，请使用句柄（Class， GenericHandler）。

Class参数必须是Message。类：

.handle(Message.class, 
    (message, headers) -> sftpSessionFactory
        .setThreadKey(message, headers.get("tenantId")))