我有以下路线:

    from("INPUT_QUEUE")
        .routeId("Test")
        .beanRef("logService", "save")
        .beanRef("deserialiser", "deserialise")


LogService中的“保存”方法返回一个整数。我不希望将此整数传递给反序列化方法。我需要来自输入队列的json进行传递。

对于我刚接触骆驼的简单问题,我们将不胜感激,并为此道歉。

最佳答案

使用multicast模式,该模式允许将同一条消息路由到多个端点并以不同的方式处理它们:

from("INPUT_QUEUE")
    .routeId("Test")
    .multicast()
        .beanRef("logService", "save")
        .beanRef("deserialiser", "deserialise")
    .end();

09-09 20:40