mule - 如何在 Mule FunctionalTestCase 中指定特定的 VM 连接器

Question

我正在尝试使用下面的 FunctionalTestCase 将消息发送到 VM 端点:

@Test
public void CreateAddToCalendarOptionsApiTest() throws Exception{

    MuleClient client = new MuleClient(muleContext);
    String payload = "foo";
    Map<String, Object> properties = null;
    MuleMessage result = client.send("vm://processActivity",  payload, properties);
    assertEquals("foo Received", result.getPayloadAsString());

}

但是，在要测试的流程中定义了多个 VM 连接器，所以我得到一个 TransportFactoryException 声明:

org.mule.transport.service.TransportFactoryException: There are at least 
2 connectors matching protocol "vm", so the connector to use must be 
specified on the endpoint using the 'connector' property/attribute. 
Connectors in your configuration that support "vm" are: inMemoryVMQueue, 
recordDeletedActivityDLQStore, recordPublishedActivityDLQStore, 
recordUpdatedActivityDLQStore, deleteQueuedActivityDLQStore,  
(java.lang.IllegalStateException)

如何指定我的 client.send("vm://processActivity", payload, properties) 使用特定的 VMConnector？

Answer 1

使用查询参数:

client.send("vm://processActivity?connector=inMemoryVMQueue",  payload, properties);

...用您要使用的任何连接器替换 inMemoryVMQueue。

它在功能上等同于端点属性。