@MockEndpoint sAndSkip不解析动态模式

Question

我正在尝试用camel-routes应用程序为我的Spring Boot编写单元测试。我的路由生产者是Kafkaendpoint，URI在应用程序中定义。属性文件。我试图模拟这个Kafka生产者endpoint，但它没有解析URI值。

@RunWith(SpringRunner.class)
@SpringBootTest
@MockEndpointsAndSkip("kafka:${kafka.servers}?*")
public class MyApplicationTests {
    @Autowired
    private CamelContext camelContext;
      ........
      //Some debug code
      // list available endpoints
      camelContext.getEndpoints().forEach((Endpoint endpoint) -> log.info("Endpoint="+endpoint));
      .............
}

在上面的psedoocode中，Kafka。在应用程序中定义了@MockEndpointsAndSkip注释的服务器值。属性文件为kafka。服务器=本地主机：9092

打印endpoint列表时，我会看到未解析的值endpoint=mock://kafka:${kafka.servers}

我希望：endpoint=mock://kafka:localhost:9092

这是错误的做法吗？

Thanx提前提供任何帮助！！

这是我的骆驼路线，我想使用MockEndpoint进行单元测试：

from("kafka:{{kafka.servers}}?topic={{kafka.consumer.topic}}&groupId={{kafka.consumer.groupId}}")
    .to("direct:notify");

from("direct:notify")
    .log("direct:notfy");

这是我的测试代码，它没有通过接收1个交换的断言。制作人似乎从未向我的Kafka Mockendpoint发送消息：

@RunWith(SpringRunner.class)
@SpringBootTest
@MockEndpointsAndSkip("kafka:{{kafka.servers}}?*|direct:notify")
public class NotificationApplicationTests {     

    @Autowired
    private CamelContext context;

    @Value("${kafka.servers}")
    private String kafkaServers;

    @EndpointInject(uri="mock:kafka:{{kafka.servers}}")
    private MockEndpoint mockKafka;

    @EndpointInject(uri="mock:direct:notify")
    private MockEndpoint mockDirect;

    @Autowired
    private ProducerTemplate notiProducer;

    @Test
    public void testMockEndpoints() throws Exception{                                       

        mockDirect.setExpectedMessageCount(1);
        mockDirect.whenAnyExchangeReceived( (Exchange exchange) -> {
            //NEVER GETS HERE!!
            log.info("MOCK DIRECT exchange received");          
        });     

        String payload = "{'email': '[e-mail]', 'data': 'ABC1234'}";

        notiProducer.sendBody(mockKafka, payload);

        mockDirect.assertIsSatisfied();

    }

}

Answer 1

您应该使用Camel的属性占位符语法

{{key}}

所以应该是这样

@MockEndpointsAndSkip("kafka:{{kafka.servers}}?*")

参见以下文档：http://camel.apache.org/using-propertyplaceholder.html

Camel不能使用${key}，因为它与Spring冲突：http://camel.apache.org/how-do-i-use-spring-property-placeholder-with-camel-xml.html