0

我正在尝试向 JMS 主题发送和接收消息。

<testcase name="DeliveryToPT3PLIT">
        ...
        <actions>
            ...              
            <send endpoint="fromEndpoint">
                <message>
                    <resource file="com/roche/icc/citrus/messages/input/PT-3PLWoBatchSplit.xml"/>
                </message>
                <header>
                    ...
                </header>
            </send>

            <receive endpoint="toEndpoint">
                <description>Receive asynchronous message from topic</description>
                <message>
                        <resource file="com/roche/icc/citrus/messages/output/PT-3PLWoBatchSplit.xml"/>
                </message>
                <header>
                    ...
                </header>
            </receive>
        </actions>
    </testcase>

这些操作似乎一个接一个。问题是我的应用程序运行得非常快，当我向第一个主题发送消息时，它几乎立即出现在“toEndpoint”上。因此接收操作无法捕获适当的消息，因为它已经被处理过。

有没有办法同时进行这些操作？

问候

4

1 回答 1

2

使用 JMS 主题有一点需要注意，因为它们以发布/订阅方式工作，您必须先订阅才能接收消息。

这意味着您需要在发布消息之前订阅该主题。此外，如果您说您的应用程序很快，您可能需要等待几毫秒才能发送消息。这是我认为可能对您有用的 Java DSL 示例。（注意：我已经用 JMS 主题测试了这个示例）

parallel().actions(
    sequential().actions( // Thread #1
            ...
            receive(action -> action.endpoint(toEndpoint).payload("message to be received"))),
    sequential().actions( // Thread #2
            sleep(500),
            send(action -> action.endpoint(fromEndpoint).payload("message to be sent"))));

注意parallel()动作容器。它将在单独的线程中执行其中的每个操作。每个都sequential()代表一系列操作，可让您将它们组合在一起。因为两个sequential()容器都在 内部parallel()，所以它们内部的动作将在不同的线程上执行。

那么这里会发生什么：你在两个线程上拆分你的操作。在第一个线程上，您等待消息。在第二个线程上，首先让它休眠 500 毫秒，然后发送消息。

很抱歉我没有 XML 示例，但我希望这对您有所帮助。

也不要忘记在端点上设置pub-sub-domain属性。true请参阅有关 JMS 主题的 Citrus 文档：此处。

于 2017-12-28T11:39:52.037 回答