在骆驼路线内重新编组原虫

Question

    <route id="Splitter">
        <from uri="activemq:notification.splitter" />
        <unmarshal ref="notificationProto" />
        <recipientList>
            <method bean="NotificationSplitter" method="splitNotification" />
        </recipientList>
    </route>

豆子工作良好，但下游的路线抱怨：-

org.apache.camel.RuntimeCamelException: java.lang.RuntimeException: Unable to find proto buffer class

下游路由的protobuf dataFormat配置与上面的路由完全相同。如果我直接路由到下游队列（即，绕过bean并硬编码“to”队列），这意味着我也可以跳过解组步骤，它工作得很好。

我想我需要在Camel将消息放入目标队列之前重新封送数据，但我不知道如何在XML中配置这一点。我试着简单地加上...

<marshal ref="notificationProto" />

J.

Answer 1

是的，数据格式不是一个易于向其发送消息的endpoint，否则，您可以使用路由滑EIP模式，将消息首先发送到数据格式，然后发送到目的地。http://camel.apache.org/routing-slip.html

虽然你可以有一条小路线

<route>
  <from uri="direct:marshalMe"/>
  <marshal ref="notificationProto" />
</route>

然后使用路由单，设置为“direct：marshalme,whereyouwannagonext”。