Camel直连MQ路由测试问题：JUnit报错及执行验证咨询

一、JUnit错误的原因与修复 #

你遇到的PreconditionViolationException是JUnit版本不兼容+测试方法规范问题导致的：

• CamelTestSupport是基于JUnit 4的测试框架，但你的测试方法误用了JUnit 5的@Test注解（来自org.junit.jupiter.api.Test），两者无法兼容。
• JUnit 4要求测试方法必须用public修饰，你的testSendingForRating方法缺少该修饰符。

修复后的测试类代码 #

import org.junit.Test;
import org.apache.camel.test.junit4.CamelTestSupport;

public class SendForRatingTest extends CamelTestSupport 
{
    @Override
    protected RouteBuilder createRouteBuilder() throws Exception {
         return new SendForRatingRoute();
    }    
    
    @Test
    public void testSendingForRating()  throws Exception 
    {       
        // 发送测试消息，若路由执行异常会直接抛出
        template.sendBody("direct:sendRate", getSampleOrder());
        // 能走到这里说明路由无异常执行完成
    }
    
    private Order getSampleOrder() {
        // 你的测试数据生成逻辑
        return new Order();
    }
}

二、验证路由执行成功的方案 #

针对无返回值的路由，且不想Mock发送过程的需求，可采用以下几种验证方式：

1. 异常捕获验证 #

虽然路由配置了onException(Exception.class).handled(true)，但如果exProcessor未完全处理异常，或路由出现未捕获的异常，template.sendBody会直接抛出异常。测试方法能正常执行完毕，就说明路由流程无错误完成。

2. 检查Exchange状态 #

通过template.send()获取Exchange对象，直接检查异常状态：

@Test
public void testSendingForRating()  throws Exception 
{       
    Exchange exchange = template.send("direct:sendRate", exchange -> {
        exchange.getIn().setBody(getSampleOrder());
    });
    // 断言路由执行无异常
    assertNull("路由执行过程中出现未处理异常", exchange.getException());
}

3. 验证成功日志输出 #

如果日志配置正常，可以捕获日志输出，验证是否出现消息发送成功的标记：

import org.apache.camel.test.junit4.CamelTestSupport;
import org.junit.Test;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import java.util.ArrayList;
import java.util.List;

public class SendForRatingTest extends CamelTestSupport 
{
    private static final Logger logger = LoggerFactory.getLogger(SendForRatingTest.class);

    @Override
    protected RouteBuilder createRouteBuilder() throws Exception {
         return new SendForRatingRoute();
    }    
    
    @Test
    public void testSendingForRating()  throws Exception 
    {       
        LoggingTestAppender appender = new LoggingTestAppender();
        appender.start();
        ((ch.qos.logback.classic.Logger) logger).addAppender(appender);
        
        template.sendBody("direct:sendRate", getSampleOrder());
        
        // 断言成功日志已输出
        assertTrue("未捕获到消息发送成功的日志", appender.getLogs().contains("~~~ Message was sent to MQ successfully "));
        
        appender.stop();
        ((ch.qos.logback.classic.Logger) logger).detachAppender(appender);
    }
    
    // 自定义日志捕获Appender
    private static class LoggingTestAppender extends ch.qos.logback.core.AppenderBase<ch.qos.logback.classic.spi.ILoggingEvent> {
        private final List<String> logs = new ArrayList<>();

        @Override
        protected void append(ch.qos.logback.classic.spi.ILoggingEvent event) {
            logs.add(event.getMessage());
        }

        public List<String> getLogs() {
            return logs;
        }
    }
}

4. 直接验证MQ队列消息（最终验证） #

如果测试环境能连接到测试用IBM MQ，可以在测试方法末尾添加代码，从MY_OUT_QUEUE消费消息，验证XML结构、数据内容是否符合预期。

额外注意事项 #

• 确保SendForRatingRoute的依赖（如exProcessor、MessagingBean）能在测试类中正确实例化，必要时在setUp()方法中手动初始化。
• 若使用Spring Boot，更推荐用@SpringBootTest结合CamelSpringBootTestSupport，能更好地集成Spring依赖注入。

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