Spring集成-Java DSL中的服务激活器

Question

我在一个简单的POJO中配置了一个服务激活器，我想将其转换为Java DSL。

现在，我的Java DSL如下所示，

public IntegrationFlow inputFlow() {
    return IntegrationFlows.from(inputChannel())
            .log(LoggingHandler.Level.DEBUG, "com.dash.messages")
            .transform(Transformers.fromJson(MessageWrapper.class, customObjectMapper()))
            .channel(theOtherChannel()))
            .get();
  }

有一个带有服务激活器的POJO，

public class MessageProcessor {

  private static final Logger logger = LoggerFactory.getLogger(MessageProcessor.class);

  ....

  @ServiceActivator
  public void handle(MessageWrapper message, @Headers Map<String, Object> headers) {
    logger.debug("Message received: " + message);
    
    // Send message to another system
    ....
  }

}

在XML中，相应的配置如下所示，

<int:service-activator input-channel="theOtherChannel"
        ref="MessageProcessor" output-channel="nullChannel" />

1. 如何在Java DSL中调用ServiceActivator方法？我正在考虑使用。handle（），但参数应该是什么
2. 在使用Java DSL时，是否有空通道的概念？如果是，我们如何指定

Answer 1

此变量：

/**
 * Populate a {@link ServiceActivatingHandler} for the
 * {@link org.springframework.integration.handler.MethodInvokingMessageProcessor}
 * to invoke the discovered {@code method} for provided {@code service} at runtime.
 * @param service the service object to use.
 * @return the current {@link BaseIntegrationFlowDefinition}.
 */
public B handle(Object service) {

因此，您只需将消息处理器自动连接到具有该集成流定义的类中，或直接连接到该inputFlow（）bean定义。然后您只需执行以下操作：

.channel(theOtherChannel()))
.handle(messageProcessor)
.get();

对于返回类型为void的service activator，无需在nullChannel中使用。不管怎样，当流遇到void或null应答时，它将在该点停止。

查看文档中的更多信息：https://docs.spring.io/spring-integration/docs/current/reference/html/dsl.html#java-dsl句柄