Mule

Question

我想编写一个 mule 应用程序，它将读取数据库中未处理的记录，将它们合并为 JSON 有效负载格式，然后访问 REST 网络服务。我能够从数据库中读取记录并能够转换 JSON 中的数据库记录。但是，每当我运行我收到以下异常的应用程序时

java.lang.ClassCastException: java.lang.String 无法转换为 java.util.Map

这是我的 Mule 配置 XML

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

<mule xmlns:db="http://www.mulesoft.org/schema/mule/db" xmlns:json="http://www.mulesoft.org/schema/mule/json" xmlns:http="http://www.mulesoft.org/schema/mule/http" 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/db http://www.mulesoft.org/schema/mule/db/current/mule-db.xsd
http://www.mulesoft.org/schema/mule/json http://www.mulesoft.org/schema/mule/json/current/mule-json.xsd
http://www.mulesoft.org/schema/mule/http http://www.mulesoft.org/schema/mule/http/current/mule-http.xsd">
    <db:mysql-config name="MySQL_Configuration" host="localhost" port="3306" user="root" database="my_database_name" doc:name="MySQL Configuration"/>
    <http:request-config name="HTTP_Request_Configuration" protocol="HTTPS" host="example.net" port="8000" basePath="API" doc:name="HTTP Request Configuration"/>
    <flow name="cwg_clientFlow">
        <poll doc:name="Poll">
            <db:select config-ref="MySQL_Configuration" doc:name="Database">
                <db:parameterized-query><![CDATA[SELECT * FROM cwg_ws_data WHERE SyncFlag = 0]]></db:parameterized-query>
            </db:select>
        </poll>
        <logger message="#[payload]" level="INFO" doc:name="Logger"/>
        <json:object-to-json-transformer   doc:name="Object to JSON" />
        <logger message="JSON Payload is #[payload]" level="INFO" doc:name="Logger"/>
        <http:request config-ref="HTTP_Request_Configuration" path="/cwg" method="POST" doc:name="HTTP">
            <http:request-builder>
                <http:query-params expression="#[payload]"/>
                <http:header headerName="access_token" value="MQTgpMUmyQLt134maB6vPp6oWFgMtGsqzIlpCN74"/>
            </http:request-builder>
        </http:request>
        <logger message="webservice response #[payload]" level="INFO" doc:name="Logger"/>
    </flow>
</mule>

我无法理解哪里出错了

请帮帮我，我从前 2 天开始就在尝试这个。

提前致谢

-Paresh (kendreparesh@gmail.com)

Answer 1

尝试删除此行。

<http:query-params expression="#[payload]"/>

应该可以。由于您的有效负载是 Json 字符串，并且您正试图将其映射到需要 Map 的查询参数。同样对于 POST，您的有效负载将转换为正文。

Answer 2

查询参数中的表达式必须是映射。如果您要将数据作为查询参数传递，为什么要反对 json？尝试删除以下两行 -

<json:object-to-json-transformer   doc:name="Object to JSON" />
        <logger message="JSON Payload is #[payload]" level="INFO" doc:name="Logger"/>

Mule - java.lang.String 无法转换为 java.util.Map

Mule - java.lang.String cannot be cast to java.util.Map

rest

classcastexception

http-request