如何在 Apache Camel 3.X.X 路由上设置标头？

Question

我正在对 Camel 路线进行集成测试。

骆驼路线：

from("direct:abc")
  .routeId("abc-route")
  .process(MyProcessor())
  .toD("direct:xyz")

由于这条路线正在被隔离测试，我需要在测试中设置标题；以前，他们是从另一条路线到达的。我该怎么做？

简化测试类：

@SpringBootTest
@MockEndpoints
@DirtiesContext(classMode = DirtiesContext.ClassMode.BEFORE_EACH_TEST_METHOD)
class MyRouteTest {

  @Autowired
  lateinit var camelContext: CamelContext

  @Produce(uri = "direct:abc")
  lateinit var template: ProducerTemplate

  @EndpointInject(uri = "mock:direct:xyz")
  lateinit var destEndpoint: MockEndpoint

  @Test
  fun `should test route`() {
    template.sendBody("")
  }
}

我已经尝试过camelContext.adapt(ModelCamelContext::class.java)，但仍然无法到达路线并强行修改它。

Answer 1

尽管已经在 cmets 中回答了，但我认为这个问题值得回答。

ProducerTemplate interface 有许多不同的方法可以将 Camel Exchange 发送到 Camel 端点。

有一些方法可以只发送消息正文、具有一个或多个标头的正文或具有一个或多个 Exchange 属性的正文。

还有一个fluent interface，可用于以良好的描述性方式自定义 Exchange。

来自 Camel Docs 的示例：

Integer result = FluentProducerTemplate.on(context)
    .withHeader("key-1", "value-1")
    .withHeader("key-2", "value-2")
    .withBody("Hello")
    .to("direct:inout")
    .request(Integer.class);