camel系列-Route和Endpoint

发表于 更新于

Route 和 Endpoint 处理规则

  • Route 和 Consumer：当使用 RouteBuilder 的 from 方法构建 endpoint 时,其调用 endpoint 的 createConsumer 创建一个 Consumer 对象，处理 from 接收的 Exchange
  • Route 和 Producer：当使用 to 方法指向下一个 endpoint 时，该指向的 endpoint 会调用 createProducer 创建一个 Producer，由 Producer 消费该消息，同时发送的端点由 consumer 转变为 Producer

示例说明

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
@Test
public void testDirect1() throws Exception {
    CamelContext context=new DefaultCamelContext();
    context.addRoutes(new RouteBuilder() {
        @Override
        public void configure() throws Exception {
            from("direct:step1").to("oss:home?bucket=curryzxh");
        }
    });
    context.start();
    ProducerTemplate producerTemplate=context.createProducerTemplate();
    producerTemplate.sendBodyAndHeader("direct:step1",
        "hello","fileName","testName");
    Thread.sleep(2000);
}

流程说明