如何在Mule 4中向端点发消息触发流？迁移Mule3异步功能遇异常

原Mule 3实现 #

在Mule 3中，通过MuleClient异步发送消息到VM队列的代码如下：

MuleClient client = new MuleClient(muleContext);
client.dispatch("vm://vm.queue", "Message Payload", null);

问题说明 #

你尝试的通过查找流并直接实例化DefaultInputEvent的方式不可行，因为org.mule.runtime.internal.event.DefaultInputEvent是Mule的内部实现类，不属于公开API，无法直接引用和实例化。

正确迁移方案 #

场景1：异步发送到VM队列 #

如果原需求是发送消息到VM队列，Mule 4推荐使用VM模块的publish组件，无需自定义代码：

<vm:publish doc:name="Publish to VM queue" config-ref="VM_Config" queueName="vm.queue">
    <vm:message>
        <vm:payload>#['Message Payload']</vm:payload>
    </vm:message>
</vm:publish>

若需在自定义Java代码中实现，可通过注入VmMessageOperations来完成：

import org.mule.runtime.extension.api.annotation.param.Config;
import org.mule.runtime.vm.api.VmMessageOperations;
import org.mule.runtime.vm.api.config.VmConfig;

public class CustomVmPublisher {

    @Config
    private VmConfig vmConfig;

    public void publishToVmQueue(String payload) {
        VmMessageOperations vmOps = vmConfig.getMessageOperations();
        // 异步发布到指定VM队列
        vmOps.publish("vm.queue", payload, null);
    }
}

场景2：异步调用指定流 #

如果需要调用另一个流，优先使用Mule 4的flow-ref组件，结合async作用域实现异步调用：

<async doc:name="Async Flow Invocation">
    <flow-ref doc:name="Call MyFlow" name="MyFlow"/>
</async>

若必须在自定义Java代码中调用流，需使用公开API构建CoreEvent并执行流：

import org.mule.runtime.core.api.MuleContext;
import org.mule.runtime.core.api.event.CoreEvent;
import org.mule.runtime.core.api.construct.Flow;
import org.mule.runtime.core.api.message.Message;

import javax.inject.Inject;

public class AsyncFlowInvoker {

    @Inject
    private MuleContext muleContext;

    public void invokeFlowAsync(String payload) {
        // 从注册表查找目标流
        Flow targetFlow = muleContext.getRegistry().lookupByName("MyFlow")
                .orElseThrow(() -> new IllegalArgumentException("Flow 'MyFlow' not found"));

        // 使用公开API构建CoreEvent
        CoreEvent event = CoreEvent.builder(muleContext.getDefaultEventContext())
                .message(Message.of(payload))
                .build();

        // 异步执行流，可通过回调处理结果
        targetFlow.process(event, result -> {
            if (result.isSuccess()) {
                // 流执行成功的处理逻辑
            } else {
                // 流执行失败的处理逻辑
            }
        });
    }
}

内容的提问来源于stack exchange，提问作者William