如何在JUnit测试中模拟Camel处理器

import org.apache.camel.CamelContext;
import org.apache.camel.EndpointInject;
import org.apache.camel.ProducerTemplate;
import org.apache.camel.builder.AdviceWithRouteBuilder;
import org.apache.camel.component.mock.MockEndpoint;
import org.apache.camel.test.junit4.CamelTestSupport;
import org.junit.Before;
import org.junit.Test;

public class MyCamelProcessorTest extends CamelTestSupport {

    @EndpointInject(uri = "mock:result")
    private MockEndpoint mockResultEndpoint;

    @Override
    protected CamelContext createCamelContext() throws Exception {
        // 创建模拟的Camel上下文
        return new MockCamelContext();
    }

    @Before
    public void setup() throws Exception {
        // 设置要测试的路由
        AdviceWithRouteBuilder.adviceWith(context, "myRoute", a -> {
            // 将原始的处理器替换为MockEndpoint
            a.replaceFromWith("direct:start");
            a.weaveById("myProcessor").replace().to(mockResultEndpoint);
        });
    }

    @Test
    public void testMyCamelProcessor() throws Exception {
        // 设置预期的消息数量
        mockResultEndpoint.expectedMessageCount(1);

        // 发送消息到路由的起始端点
        template.sendBody("direct:start", "Test Message");

        // 断言是否收到了预期的消息
        mockResultEndpoint.assertIsSatisfied();
    }
}