Apache Camel 报错 - InvalidPayloadException ， NoTypeConversionAvailableException

0 0

Apache Camel 报错 - InvalidPayloadException ， NoTypeConversionAvailableException5

Caused by: org.apache.camel.InvalidPayloadException: No body available of type: java.io.InputStream but has value: com.c2r.service.event.model.AtomMessage@6ae71afb of type: com.c2r.service.event.model.AtomMessage on: JmsMessage[JmsMessageID: ID:SRCLNLnxES02-53298-1383528270091-89:44:1:1:1]. Caused by: No type converter available to convert from type: com.c2r.service.event.model.AtomMessage to the required type: java.io.InputStream with value com.c2r.service.event.model.AtomMessage@6ae71afb. Exchange[JmsMessage[JmsMessageID: ID:SRCLNLnxES02-53298-1383528270091-89:44:1:1:1]]. Caused by: [org.apache.camel.NoTypeConversionAvailableException - No type converter available to convert from type: com.c2r.service.event.model.AtomMessage to the required type: java.io.InputStream with value com.c2r.service.event.model.AtomMessage@6ae71afb]
        at org.apache.camel.impl.MessageSupport.getMandatoryBody(MessageSupport.java:101)[115:org.apache.camel.camel-core:2.10.4]
        at org.apache.camel.processor.UnmarshalProcessor.process(UnmarshalProcessor.java:51)[115:org.apache.camel.camel-core:2.10.4]
        at org.apache.camel.util.AsyncProcessorConverterHelper$ProcessorToAsyncProcessorBridge.process(AsyncProcessorConverterHelper.java:61)[115:org.apache.camel.camel-core:2.10.4]
        at org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:73)[115:org.apache.camel.camel-core:2.10.4]
        at org.apache.camel.processor.DelegateAsyncProcessor.processNext(DelegateAsyncProcessor.java:99)[115:org.apache.camel.camel-core:2.10.4]
        at org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:90)[115:org.apache.camel.camel-core:2.10.4]
        at org.apache.camel.management.InstrumentationProcessor.process(InstrumentationProcessor.java:72)[115:org.apache.camel.camel-core:2.10.4]
        at org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:73)[115:org.apache.camel.camel-core:2.10.4]
        at org.apache.camel.process

Spring DSL如下：
<camelContext xmlns="http://camel.apache.org/schema/spring">
<dataFormats>
    <json id="jsonAtomMessage" library="Jackson" unmarshalTypeName="com.c2r.service.event.model.AtomMessage"/>
</dataFormats>
<route>
<from uri="activemq:queue:c2r.eventservice.event.atom.message?jmsMessageType=Object" />
    <multicast stopOnException="true">
        <to uri="bean:atomMessageReceiver?method=save" />
        <choice>
            <when>
<simple>${in.header.JMSCorrelationId}== 'PromotionCouponReward'</simple>
<unmarshal ref="jsonAtomMessage"/>
<to uri="activemq:queue:cln.game.coupon.redeem?jmsMessageType=Text"/>
            </when>
        </choice>
    </multicast>
</route>
</camelContext>

unmarshal是为了把java object消息转换成json文本，转发到另外一个jms queue

各位大侠请指教