Camel 路由示例

以下路线有一个简单的目标:

  • 首先,它检查数据库中是否存在和 ImportDocumentProcess 对象,并将其添加为交换头
  • 然后,它在数据库中添加 ImportDocumentTraitement (链接到先前的 ImportDocumentProcess)

以下是此路线的代码:

@Component
public class TestExampleRoute extends SpringRouteBuilder {

    public static final String ENDPOINT_EXAMPLE = "direct:testExampleEndpoint";

    @Override
    public void configure() throws Exception {
        from(ENDPOINT_EXAMPLE).routeId("testExample")
            .bean(TestExampleProcessor.class, "getImportDocumentProcess").id("getImportDocumentProcess")
            .bean(TestExampleProcessor.class, "createImportDocumentTraitement").id("createImportDocumentTraitement")
            .to("com.pack.camel.routeshowAll=true&multiline=true");
    }

}

ID 的路线是不是强制性的,你可以使用 bean 字符串之后了。但是我认为使用 id 可以被认为是一种很好的做法,以防你的路由字符串在将来发生变化。