我有以下路线:
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();