Apache Camel 多播 notifyBuilder 失败

Question

出于某种原因，QUEUE_A 并不总是有 1 个交换 - 有时它有 0，除非我在测试中添加一个 Thread.sleep(100)。我猜 whenCompleted/whenDone 实际上说它已经完成时并没有完全完成。如何验证它是否已完全完成？

multicast().parallelProcessing().to(QUEUE_A, QUEUE_B, QUEUE_C, QUEUE_D)

和测试：

@Test
public void test() {
    NotifyBuilder notify = new NotifyBuilder(context)
            .from(QUEUE_INCOMING)
            .whenCompleted(1)
            .create();
    template.sendBody(QUEUE_INCOMING, streamToString(loadResourceAsStream("/data/TestData.xml")));

    boolean matches = notify.matches(4, SECONDS);
    assertTrue("Notify failed", matches);
    Thread.sleep(100); //Without this, it fails 

    verifyEndpoints(1, context, QUEUE_A, QUEUE_B, QUEUE_C, QUEUE_D);
}

public static void verifyEndpoints(int expectedSize, ModelCamelContext context, String... endpoints) {
    for (String endpoint : endpoints) {
        BrowsableEndpoint be = context.getEndpoint(endpoint, BrowsableEndpoint.class);
        assertThat(String.format("Endpoint exchanges '%s' has wrong size", endpoint), be.getExchanges(), hasSize(expectedSize));
    }
}

还有端点 bean，在测试时使用 ActiveMQ，但在 prod 中将使用 WebSphere MQ：

<bean id="wmq" class="org.apache.camel.component.jms.JmsComponent">
    <property name="connectionFactory">
      <bean class="org.apache.activemq.ActiveMQConnectionFactory">
        <property name="brokerURL" value="vm://localhost?broker.persistent=false" />
      </bean>
    </property>
</bean>

Answer 1

问题是您在向 WMQ 发送消息后尽快浏览它，因此取决于代理实现和时间等，在使用 JMS 浏览 api 时您可能看不到最后的消息。

因此，当您稍等片刻时，它似乎可以修复。