问题测试多个Spring-Cloud-Stream应用程序

Question

场景：我有3个Spring Cloud流媒体应用程序

• 1'st：将XML有效负载解组为JAXB对象
• 2'nd：将JAXB有效负载转换为我们的域POJO
• 3'rd：验证域对象

我正在尝试测试第三个应用程序。我已将第一个和第二个应用程序作为测试依赖项。我添加了：

    <dependency>
        <groupId>org.springframework.cloud</groupId>
        <artifactId>spring-cloud-stream-test-support</artifactId>
        <scope>test</scope>
    </dependency>

现在，我有大约20个xml文件，其中包含各种验证场景。第一个测试运行良好。我能够通过以下方式获取频道的预期消息：

    final Message<PaymentInstruction> mceMessage =
            (Message<PaymentInstruction>) collector.forChannel(
                    validationBindings.mce()).take();

运行的第二个测试是我有问题的地方。测试只是坐在“获取”处。

我在spring-integration-core-4.3.8中做了一些挖掘。jar并已将问题跟踪到org。springframework。集成。调度员。AbstractDispatcher：

@Override
public synchronized boolean addHandler(MessageHandler handler) {
    Assert.notNull(handler, "handler must not be null");
    Assert.isTrue(this.handlers.size() < this.maxSubscribers, "Maximum subscribers exceeded");
    boolean added = this.handlers.add(handler);
    if (this.handlers.size() == 1) {
        this.theOneHandler = handler;
    }
    else {
        this.theOneHandler = null;
    }
    return added;
}

有一个为第一个测试添加的处理程序，因此它将null分配给“this”。theOneHandler'

我的选择是：

• 重构其他两个项目中的代码，这样我就可以进行域对象的解组和创建，而不需要spring cloud应用程序代码
• 我可以为每个测试用例创建一个单独的单元测试类，但是我不想走这条路，因为spring boot的启动时间很长，会乘以测试用例的数量
• 我是否缺少一些允许我拥有这些多个处理程序的配置，或者我是否打破了我想要使用Spring-Cloud-Stream的方式

环境：

• Java8更新131
• org.springframework.cloud：Spring云依赖项：Dalston。释放
• org.springframework.boot：spring-boot-依赖项：1.5.2。释放

Answer 1

当一个频道只有一个订户时，one Handler是一种调度优化。

听起来您将所有服务绑定到同一个频道，这不是您想要的。

归根结底，您不能做您想做的事情，因为每个服务都使用相同的频道名称（可能是输入）。

您需要在单独的应用程序上下文中加载每个服务，并使用网桥将它们连接在一起。

编辑

您还可以使用聚合应用程序测试它们。