如何在 Camel 中的自定义拆分器之后链接路由器

Question

我想从 JSON 负载中提取文档，并根据它们的位置将它们发送到不同的处理器。

JSON:

{
    "email" : {
        "documents" : [{
                "name" : "Document 1",
                "id" : "1111"
            }, {
                "name" : "Document 2",
                "id" : "222"
            }
        ]
    },
    "sms" : {
        "documents" : [{
                "name" : "Document 3",
                "id" : "3333"
            }, {
                "name" : "Document 4",
                "id" : "4444"
            }
        ]
    }
}

我想通过做这样的事情来实现：

from("servlet:///doc").unmarshal()
  .json(JsonLibrary.Jackson, DocumentRequest.class)
  .split().method("docSplit", "split")
  .choice()
    .when().header("mode").isEqualTo("email")
      .to("direct:email")
    .when().header("mode").isEqualTo("sms")
      .to("direct:sms");

我的拆分器可以接收 DocumentRequest 并提取所有文档...但我不知道如何设置 "mode" header 以供将来路由。

如何设置 "mode" header？

是否有更好的整体方法？

Answer 1

您始终可以将自定义拆分逻辑放入自定义处理器中并使用 ProducerTemplate

例如：

    from("servlet:///doc").unmarshal()
              .json(JsonLibrary.Jackson, DocumentRequest.class)
              .process(new Processor()  {
                    @Override
                    public void process(Exchange exchange) throws Exception {
                        ProducerTemplate producer=exchange.getContext().createProducerTemplate();

                        String mode;
                        for (Document doc: // split and set mode logic goes here ) {
                            if (mode.compareToIgnoreCase("email") ==0) {
                                producer.sendBody("direct:email", doc);
                            } else 
                            if (mode.compareToIgnoreCase("sms") ==0) {
                                producer.sendBody("direct:sms", doc);
                            }
...
                        }
                    }
              });

如何在 Camel 中的自定义拆分器之后链接路由器

How to chain a router after a custom splitter in Camel

json

splitter

apache-camel

eip