DataWeave 的 MIME 类型无效

Question

我正在尝试在 Mule ESB（企业版）中创建一个流，该流从 WMQ 7.5（xml 有效负载）中的队列接收消息，使用 DataWeave 将其转换（出于我的目的，将其转换为一个新的 xml 文件与旧的相同），然后将其放回另一个队列。我的流程如下：

<?xml version="1.0" encoding="UTF-8"?>

<mule xmlns:mulexml="http://www.mulesoft.org/schema/mule/xml" xmlns:metadata="http://www.mulesoft.org/schema/mule/metadata" xmlns:dw="http://www.mulesoft.org/schema/mule/ee/dw" xmlns:wmq="http://www.mulesoft.org/schema/mule/ee/wmq" xmlns="http://www.mulesoft.org/schema/mule/core" xmlns:doc="http://www.mulesoft.org/schema/mule/documentation"
    xmlns:spring="http://www.springframework.org/schema/beans" 
    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-current.xsd
http://www.mulesoft.org/schema/mule/core http://www.mulesoft.org/schema/mule/core/current/mule.xsd
http://www.mulesoft.org/schema/mule/ee/wmq http://www.mulesoft.org/schema/mule/ee/wmq/current/mule-wmq-ee.xsd
http://www.mulesoft.org/schema/mule/ee/dw http://www.mulesoft.org/schema/mule/ee/dw/current/dw.xsd
http://www.mulesoft.org/schema/mule/xml http://www.mulesoft.org/schema/mule/xml/current/mule-xml.xsd">
    <wmq:connector (MQ configuration is here, it is not the problem) />
    <flow name="dataweaveFlow">
        <wmq:inbound-endpoint queue="I0" connector-ref="WMQ" doc:name="WMQ">
            <wmq:transaction action="ALWAYS_BEGIN"/>
        </wmq:inbound-endpoint>
        <set-variable variableName="MULE_REPLYTO_STOP" value="true" doc:name="Variable"/>
        <dw:transform-message doc:name="Transform Message">
            <dw:input-payload doc:sample="empty_1.xml"/>
            <dw:set-payload><![CDATA[%dw 1.0
%input payload application/xml
%output application/xml
---
payload]]></dw:set-payload>
        </dw:transform-message>

        <wmq:outbound-endpoint queue="O0" connector-ref="WMQ" doc:name="WMQ">
            <wmq:transaction action="ALWAYS_JOIN"/>
        </wmq:outbound-endpoint>
    </flow>
</mule>

我的 DataWeave 配置如下所示： 输入：

<?xml version='1.0' encoding='windows-1252'?>
<empty/>

转换：

  %dw 1.0
%input payload application/xml
%output application/xml
---
payload

现在，当我运行此流程时，我将一条消息放入队列，Mule 无法处理该消息并不断抛出异常，说：“Invalid mime type application/xml”，异常堆栈为 1。无效的 mime 类型 application/xml (com.mulesoft.weave.mule.exception.InvalidMimeTypeException) com.mulesoft.weave.mule.WeaveMessageProcessor:165 (null) 2. 无效的 mime 类型 application/xml (com.mulesoft.weave.mule.异常.InvalidMimeTypeException）。消息负载类型：String (org.mule.api.MessagingException) org.mule.execution.ExceptionToMessagingExceptionExecutionInterceptor:32 (http://www.mulesoft.org/docs/site/current3/apidocs/org/mule/api/MessagingException.html)

无论如何，我对 Mule（当然还有 DataWeave）还很陌生，我们将不胜感激！如果需要更多详细信息，请告诉我。

Answer 1

正如您之前提到的，没有使用 %input 指令。它将从 Studio 自动完成功能中移除。

强制 DataWeave 使用阅读器的方法是使用 mimeType 属性或您提到的使用 set-property，因为这将强制 Mule 消息具有 MimeType

Answer 2

这个问题比较模糊，我找到的解决方案更奇怪。 我只是在我的 Data Weaver/Transform Message 之后和我的 WMQ 出站端点之前添加了一个“对象到字符串”转换器，它就可以工作了。问题是数据编织器始终提供“com.mulesoft.weave.mule.WeaveMessageProcessor$WeaveOutputHandler”的输出。

请尝试此修复...我很确定它会起作用。

Answer 3

在报告错误后，发现 WMQ、DataWeave 和 同步处理策略 的组合引发了这个奇怪的异常。补丁已经可用，它将在 ESB 的未来版本中修复，但现在您可以联系支持并询问 SE-3167。 祝你好运！

Answer 4

Mule 支持人员和我经过长时间的交谈后，发现这是一个错误。在我的票上，目前正在由工程团队进行处理。当您的主要流程处理策略设置为synchronous 而不是queued asynchronous 时，就会发生这种情况。

尝试通过单击您的主要流程进行测试，并将处理策略专门设置为queued asynchronous。

请注意，您将无法将 WMQ 事务性与 queued asynchronous 处理策略一起使用，因此我对这个错误感到沮丧。

Answer 5

如果您从输入源获取 XML，首先假设说 WMQ 连接器将 MIME 类型设置为 application/xml 。 要将 MIME 类型设置为 application/xml，请右键单击 WMQ 连接器，然后单击高级并设置 MIME 类型：application/xml。

您正在返回%output application/xml，所以我建议您在数据编织组件之后使用DOM to XML Transformer。我认为它会起作用。

Answer 6

在 Dataweave 之前向 XML 添加一个 Transformer 对象，这会将您的消息转换为正确的格式。