出站Httpendpoint的Spring集成测试

Question

我是Spring集成项目的新手，现在我需要用JavaDSL创建一个流并对其进行测试。我想出了这些流程。第一个应该由cron运行并调用第二个，后者调用HTTPendpoint并将XML响应转换为POJO：

  @Bean
  IntegrationFlow pollerFlow() {
    return IntegrationFlows
        .from(() -> new GenericMessage<>(""),
            e -> e.poller(p -> p.cron(this.cron)))
        .channel("pollingChannel")
        .get();
  }

  @Bean
  IntegrationFlow flow(HttpMessageHandlerSpec bulkEndpoint) {
    return IntegrationFlows
        .from("pollingChannel")
        .enrichHeaders(authorizationHeaderEnricher(user, password))
        .handle(bulkEndpoint)
        .transform(xmlTransformer())
        .channel("httpResponseChannel")
        .get();
  }

  @Bean
  HttpMessageHandlerSpec bulkEndpoint() {
    return Http
        .outboundGateway(uri)
        .httpMethod(HttpMethod.POST)
        .expectedResponseType(String.class)
        .errorHandler(new DefaultResponseErrorHandler());
  }

现在我想测试流和模拟HTTP调用，但努力模拟HTTP处理程序，我尝试这样做：

@ExtendWith(SpringExtension.class)
@SpringIntegrationTest(noAutoStartup = {"pollerFlow"})
@ContextConfiguration(classes = FlowConfiguration.class)
public class FlowTests {

  @Autowired
  private MockIntegrationContext mockIntegrationContext;
  @Autowired
  public DirectChannel httpResponseChannel;
  @Autowired
  public DirectChannel pollingChannel;

  @Test
  void test() {
    final MockMessageHandler mockHandler = MockIntegration.mockMessageHandler()
        .handleNextAndReply(message -> new GenericMessage<>(xml, message.getHeaders()));
    mockIntegrationContext.substituteMessageHandlerFor("bulkEndpoint", mockHandler);
    httpResponseChannel.subscribe(message -> {
      assertThat(message.getPayload(), is(notNullValue()));
      assertThat(message.getPayload(), instanceOf(PartsSalesOpenRootElement.class));
    });

    pollingChannel.send(new GenericMessage<>(""));
  }
}

但我总是在网上出错：

mockIntegrationContext。替换信息Handlerfor（“bulkEndpoint”，mockHandler）；

org.springframework.beans.factory.BeanNotOfRequiredTypeException: Bean named 'bulkEndpoint' is expected to be of type 'org.springframework.integration.endpoint.IntegrationConsumer' but was actually of type 'org.springframework.integration.http.outbound.HttpRequestExecutingMessageHandler'

我在这里做错了什么吗？我假设我对集成流本身有问题，或者我的测试方法有问题。

Answer 1

错误是正确的。bulkEndpoint本身不是endpoint。它实际上是一个消息处理程序。endpoint是从创建的。句柄（bulkEndpoint）。见文件：https://docs.spring.io/spring-integration/docs/current/reference/html/overview.html#finding-html" target="_blank">java和dsl配置的类名，以及https://docs.spring.io/spring-integration/docs/current/reference/html/testing.html#testing-嘲笑。

所以，为了让它工作，你需要做这样的事情：

.handle(bulkEndpoint, e -> e.id("actualEndpoint"))

然后在测试中：

mockIntegrationContext.substituteMessageHandlerFor("actualEndpoint", mockHandler);

您可能还需要考虑在测试时不要启动污染流，您可以手动将消息发送到污染通道中。因此，与您想要测试的内容没有冲突。因此，您还可以将id（）添加到e.poller（p-