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));
    }
}

和endpointbean,在测试时使用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发送消息后，您会尽快浏览WMQ，因此，在使用JMS browsing API时，您可能看不到最后的消息，这取决于代理实现和时间等。

这就是为什么当你在睡眠中等待一段时间时，它似乎会被修复。