java - 使用 Mule 调用将 MuleMessage 传递给 Java 方法

标签 java mule

我有一个 Java 方法可以读取一些流变量,进行一些聚合并将结果附加到另一个流变量中已经存在的列表中。

因此,该方法需要一个 MuleMessage。我认为显然可以将 MuleMessage 传递给 java 方法,使用 message MEL 变量,例如:

<invoke object-ref="Aggregator" method="aggregateSingle" methodArguments="#[message]" doc:name="Invoke"/>

但事实证明,这传递了一个 MessageContext 对象。但是我需要设置 InvocationVariable 所以这个类没有用。我知道我已经在 groovy 中设置了变量,所以也许这会起作用(我认为):

<invoke object-ref="Aggregator" method="aggregateSingle" methodArguments="#[groovy:message]" doc:name="Invoke"/>

但是不,这以某种方式传递了 payload 而不是 MuleMessage

所以我发现这样做的唯一方法是在 Groovy 组件中实际调用它,如下所示。这意味着我必须每次都创建一个新的 Aggregator 对象,而不是像我计划的那样使用 spring:bean

                <scripting:transformer doc:name="aggregateSingle">
                    <scripting:script engine="Groovy"><![CDATA[
                        new com.example.Aggregator().aggregateSingle(message);
                        message
                    ]]></scripting:script>
                </scripting:transformer> 

没有办法使用 invokeMuleMessage 对象传递给 Java 方法吗?

最佳答案

默认情况下,mel 使用消息上下文来引用消息变量,这实际上只是为了帮助处理常见的表达式,例如 message.payload != null(在以前版本的 mule 中,您必须检查空负载) .我已经调试了 invoke 元素,不幸的是没有表达式会删除它,但这是您可以使用的等效方法

<expression-transformer expression="#[groovy: Aggregator.aggregateSingle(message)]" />

这按预期工作,因为 groovy 可以直接访问 bean 注册表,因此您可以引用 bean 名称并将其保留为 spring bean(正如我想象的那样)

关于java - 使用 Mule 调用将 MuleMessage 传递给 Java 方法,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/31258097/

相关文章:

java - 通过调用堆栈自省(introspection)的方法签名

maven - 使用 Maven 从域项目创建 Mule 可部署存档

java - 如何在Tomcat中启动Mule?

java - 客户端和服务器之间使用套接字进行通信

java - 反序列化名称不一致的对象属性?

java - Mule 聚合器 - 流聚合

error-handling - m子流的错误通知

mule - mule 中的入站终点和出站终点究竟是什么?

Java Codelab 字母计数器

java - 可以改变 JButton 的形状吗?