0

我需要从我在 spring bean 中收到的交换对象中获取 SOAP 消息。

我有一条骆驼路线，它从服务端点路由到我的 java bean。Spring 中声明的 Java Bean 和 Camel 路由如下所示：

<bean id="processor" class="com.groupgti.esb.camel.wrapper.gradireland.userregistration.UserRegistrationProcessor">

<camel:route id="route">
    <camel:from uri="cxf:bean:myListenerEndpoint?dataFormat=PAYLOAD&amp;synchronous=true" />
    <camel:bean ref="processor" />
    <camel:to uri="cxf:bean:myTargetEndpoint"/>
</camel:route>

在我的 java bean 中，我收到了交换对象：

@Override
public SOAPMessage processMessage(Exchange exchange) {
    Object object = exchange.getIn().getHeaders().get("CamelCxfMessage");
    LOGGER.debug("Object: " + object);
    SOAPMessage message = null;

    if (object instanceof SOAPMessage) {
        message = (SOAPMessage) object;
        LOGGER.debug("Got message: " + message);
    }

    LOGGER.debug("Sending message...");
    return message;
}

问题是我无法从交换中获取 SOAP 消息。我骆驼网站，在这里我发现我必须使用它来获取 SOAP 消息：

SOAPMessage soapMessage = (SOAPMessage) exchange.getIn().getBody(List.class).get(0);

但他给了我NullPointerException一些深刻的交换。

我试图调试并查看对象树。我发现我可以收到这样的消息：

SOAPMessage soapMessage = (SOAPMessage) exchange.getIn().getHeaders().get("CamelCxfMessage");

但这给了我这个例外：

org.apache.camel.ExpectedBodyTypeException: Could not extract IN message body as type: interface javax.xml.transform.Source body is: null

我被困在这里。也许有人知道问题出在哪里？

4

1 回答 1

2

PAYLOAD 模式不是很简单，也许你应该尝试 CXF 的 POJO 模式，并摆脱 SoapMessage。您必须使用 JAXB 注释声明 POJO，例如

@XmlAccessorType(XmlAccessType.FIELD)
public class Registration {

    private Long roomNumber;
    ...

}

这将允许您直接在处理器中的注册类上工作（我认为这是您的最终目标）。

Registration registration = exchange.getIn().getBody(Registration.class);

如果您坚持使用 PAYLOAD 模式，请注意您可以编写

SOAPMessage soapMessage = exchange.getIn().getHeader(CxfConstants.CAMEL_CXF_MESSAGE, SOAPMessage.class);
于 2012-07-27T14:22:08.803 回答