Spring集成流中的对象方法参考

Question

在通道上接收消息，并由变压器处理。变压器的输出是以下类，它被传递到流程中的下一步：

public class DomainBean{

   public DomainBean process() {
      // code
      return this;
   }

}

另一个bean有一个Transformer方法，该方法在上面的bean上调用process方法，如下所示：

@Component
public class Handler {

    @Transformer
    public Object handle(Message<?> message) throws MessagingException {
        DomainBean domainBean = (DomainBean) message;
        domainBean.process();
        return domainBean ;
    }

}

在IntegrationFlow中，调用handle方法如下：

.transform(handler)

理想情况下，我希望去掉处理程序bean类，并调用域bean。process（）使用对象方法引用，如下所示：

.transform(DomainBean::process)

当我试着那样做的时候，或者说。

Non-static method cannot be referenced from a static context

有什么办法能让这一切成功吗？

谢谢

Answer 1

你的问题不清楚。IntegrationFlow定义中确实有这个方法：

 * Populate the {@link MessageTransformingHandler} instance for the provided {@link GenericTransformer}.
 * @param genericTransformer the {@link GenericTransformer} to populate.
 * @param <S> the source type - 'transform from'.
 * @param <T> the target type - 'transform to'.
 * @return the current {@link IntegrationFlowDefinition}.
 * @see MethodInvokingTransformer
 * @see LambdaMessageProcessor
 */
public <S, T> B transform(GenericTransformer<S, T> genericTransformer) {

其中GenericTransformer确实可以表示为lambda或方法引用，我们有足够的测试来确认这一点。那里的代码看起来像：

.transform("hello "::concat)
...
.<String, Integer>transform(Integer::parseInt)
...
.<String, String>transform(String::toUpperCase)
...
.<MessagingException,  Message<?>>transform(MessagingException::getFailedMessage)

也许你的问题是你需要在方法中添加精确的泛型agrs？因此：

.<DomainBean, DomainBean>transform(DomainBean::process)

然而，我看到您的DomainBean.process（）是val。此签名不符合转换器的目的。是的，您可以使用Handler中的lambda执行相同的操作，或者另一种解决方案是使用. hand（）。这个确实可以调用val方法，老实说，这正是适合您的逻辑的-到目前为止还没有任何转换逻辑。

然而，当服务方法为void时，该方法在流中调用后没有任何连续性。这样一个<代码>。handle（）必须是流定义中的最后一个单向endpoint。void等于出站通道适配器。